com.facebook.buck.remoteexecution.grpc

Class GrpcCasBlobUploader

java.lang.Object

com.facebook.buck.remoteexecution.grpc.GrpcCasBlobUploader

All Implemented Interfaces:

CasBlobUploader

public class GrpcCasBlobUploader
extends Object
implements CasBlobUploader

GRPC implementation of the CasBlobUploader.

Nested Class Summary

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

CasBlobUploader.UploadResult

Constructor Summary

Constructors

Constructor and Description
GrpcCasBlobUploader(String instanceName, build.bazel.remote.execution.v2.ContentAddressableStorageGrpc.ContentAddressableStorageFutureStub storageStub, com.google.bytestream.ByteStreamGrpc.ByteStreamStub byteStreamStub, BuckEventBus buckEventBus, com.facebook.buck.remoteexecution.proto.RemoteExecutionMetadata metadata)

Method Summary

Modifier and Type	Method and Description
com.google.common.collect.ImmutableList<CasBlobUploader.UploadResult>	batchUpdateBlobs(com.google.common.collect.ImmutableList<UploadDataSupplier> blobs)
com.google.common.collect.ImmutableSet<String>	getMissingHashes(Set<Protocol.Digest> requiredDigests)
CasBlobUploader.UploadResult	uploadFromStream(UploadDataSupplier blob)

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcCasBlobUploader

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

Method Detail

getMissingHashes

public com.google.common.collect.ImmutableSet<String> getMissingHashes(Set<Protocol.Digest> requiredDigests)
                                                                throws IOException

Specified by:

getMissingHashes in interface CasBlobUploader

Throws:

IOException

batchUpdateBlobs

public com.google.common.collect.ImmutableList<CasBlobUploader.UploadResult> batchUpdateBlobs(com.google.common.collect.ImmutableList<UploadDataSupplier> blobs)
                                                                                       throws IOException

Specified by:

batchUpdateBlobs in interface CasBlobUploader

Throws:

IOException

uploadFromStream

public CasBlobUploader.UploadResult uploadFromStream(UploadDataSupplier blob)
                                              throws IOException

Specified by:

uploadFromStream in interface CasBlobUploader

Throws:

IOException