com.facebook.buck.remoteexecution.grpc

Class GrpcContentAddressableStorageClient

java.lang.Object

com.facebook.buck.remoteexecution.grpc.GrpcContentAddressableStorageClient

All Implemented Interfaces:

ContentAddressedStorageClient

public class GrpcContentAddressableStorageClient
extends Object
implements ContentAddressedStorageClient

Implementation of a CAS client using GRPC.

Nested Class Summary

Nested classes/interfaces inherited from interface com.facebook.buck.remoteexecution.ContentAddressedStorageClient

ContentAddressedStorageClient.FileMaterializer

Constructor Summary

Constructors

Constructor and Description

GrpcContentAddressableStorageClient(build.bazel.remote.execution.v2.ContentAddressableStorageGrpc.ContentAddressableStorageFutureStub storageStub, com.google.bytestream.ByteStreamGrpc.ByteStreamStub byteStreamStub, int casDeadline, String instanceName, Protocol protocol, BuckEventBus buckEventBus, com.facebook.buck.remoteexecution.proto.RemoteExecutionMetadata metadata, int outputMaterializationThreads)

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<Unit>	addMissing(Collection<UploadDataSupplier> data)
boolean	containsDigest(Protocol.Digest digest)
com.google.common.util.concurrent.ListenableFuture<ByteBuffer>	fetch(Protocol.Digest digest)
com.google.common.util.concurrent.ListenableFuture<Unit>	materializeOutputs(List<Protocol.OutputDirectory> outputDirectories, List<Protocol.OutputFile> outputFiles, ContentAddressedStorageClient.FileMaterializer materializer) Materializes the outputFiles and outputDirectories into root.

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcContentAddressableStorageClient

public GrpcContentAddressableStorageClient(build.bazel.remote.execution.v2.ContentAddressableStorageGrpc.ContentAddressableStorageFutureStub storageStub,
                                           com.google.bytestream.ByteStreamGrpc.ByteStreamStub byteStreamStub,
                                           int casDeadline,
                                           String instanceName,
                                           Protocol protocol,
                                           BuckEventBus buckEventBus,
                                           com.facebook.buck.remoteexecution.proto.RemoteExecutionMetadata metadata,
                                           int outputMaterializationThreads)

Method Detail

addMissing

public com.google.common.util.concurrent.ListenableFuture<Unit> addMissing(Collection<UploadDataSupplier> data)
                                                                    throws IOException

Specified by:

addMissing in interface ContentAddressedStorageClient

Throws:

IOException

materializeOutputs

public com.google.common.util.concurrent.ListenableFuture<Unit> materializeOutputs(List<Protocol.OutputDirectory> outputDirectories,
                                                                                   List<Protocol.OutputFile> outputFiles,
                                                                                   ContentAddressedStorageClient.FileMaterializer materializer)
                                                                            throws IOException

Description copied from interface: ContentAddressedStorageClient

Materializes the outputFiles and outputDirectories into root.

Specified by:

materializeOutputs in interface ContentAddressedStorageClient

Throws:

IOException

containsDigest

public boolean containsDigest(Protocol.Digest digest)

Specified by:

containsDigest in interface ContentAddressedStorageClient

fetch

public com.google.common.util.concurrent.ListenableFuture<ByteBuffer> fetch(Protocol.Digest digest)

Specified by:

fetch in interface ContentAddressedStorageClient