com.facebook.buck.remoteexecution.grpc

Class GrpcRemoteExecutionClients

java.lang.Object

com.facebook.buck.remoteexecution.grpc.GrpcRemoteExecutionClients

All Implemented Interfaces:

RemoteExecutionClients, Closeable, AutoCloseable

public class GrpcRemoteExecutionClients
extends Object
implements RemoteExecutionClients

A RemoteExecution that sends jobs to a grpc-based remote execution service.

Field Summary

Fields

Modifier and Type	Field and Description
static Protocol	PROTOCOL

Constructor Summary

Constructors

Constructor and Description
GrpcRemoteExecutionClients(String instanceName, io.grpc.ManagedChannel executionEngineChannel, io.grpc.ManagedChannel casChannel, int casDeadline, MetadataProvider metadataProvider, BuckEventBus buckEventBus, RemoteExecutionStrategyConfig strategyConfig)

Method Summary

Modifier and Type	Method and Description
void	close()
ContentAddressedStorageClient	getContentAddressedStorage()
Protocol	getProtocol()
RemoteExecutionServiceClient	getRemoteExecutionService()
static String	getResourceName(String instanceName, Protocol.Digest digest)
static com.google.common.util.concurrent.ListenableFuture<Unit>	readByteStream(String instanceName, Protocol.Digest digest, com.google.bytestream.ByteStreamGrpc.ByteStreamStub byteStreamStub, ThrowingConsumer<com.google.protobuf.ByteString,IOException> dataConsumer, int casDeadline) Reads a ByteStream onto the arg consumer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PROTOCOL

public static final Protocol PROTOCOL

Constructor Detail

GrpcRemoteExecutionClients

public GrpcRemoteExecutionClients(String instanceName,
                                  io.grpc.ManagedChannel executionEngineChannel,
                                  io.grpc.ManagedChannel casChannel,
                                  int casDeadline,
                                  MetadataProvider metadataProvider,
                                  BuckEventBus buckEventBus,
                                  RemoteExecutionStrategyConfig strategyConfig)

Method Detail

getResourceName

public static String getResourceName(String instanceName,
                                     Protocol.Digest digest)

readByteStream

public static com.google.common.util.concurrent.ListenableFuture<Unit> readByteStream(String instanceName,
                                                                                      Protocol.Digest digest,
                                                                                      com.google.bytestream.ByteStreamGrpc.ByteStreamStub byteStreamStub,
                                                                                      ThrowingConsumer<com.google.protobuf.ByteString,IOException> dataConsumer,
                                                                                      int casDeadline)

Reads a ByteStream onto the arg consumer.

getRemoteExecutionService

public RemoteExecutionServiceClient getRemoteExecutionService()

Specified by:

getRemoteExecutionService in interface RemoteExecutionClients

getContentAddressedStorage

public ContentAddressedStorageClient getContentAddressedStorage()

Specified by:

getContentAddressedStorage in interface RemoteExecutionClients

getProtocol

public Protocol getProtocol()

Specified by:

getProtocol in interface RemoteExecutionClients

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException