public class GrpcCasBlobUploader extends Object implements CasBlobUploader
CasBlobUploader.UploadResult
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) |
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) |
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)
public com.google.common.collect.ImmutableSet<String> getMissingHashes(Set<Protocol.Digest> requiredDigests) throws IOException
getMissingHashes
in interface CasBlobUploader
IOException
public com.google.common.collect.ImmutableList<CasBlobUploader.UploadResult> batchUpdateBlobs(com.google.common.collect.ImmutableList<UploadDataSupplier> blobs) throws IOException
batchUpdateBlobs
in interface CasBlobUploader
IOException
public CasBlobUploader.UploadResult uploadFromStream(UploadDataSupplier blob) throws IOException
uploadFromStream
in interface CasBlobUploader
IOException