com.facebook.buck.remoteexecution.grpc

Class GrpcAsyncBlobFetcher

java.lang.Object

com.facebook.buck.remoteexecution.grpc.GrpcAsyncBlobFetcher

All Implemented Interfaces:

AsyncBlobFetcher

public class GrpcAsyncBlobFetcher
extends Object
implements AsyncBlobFetcher

GRPC implementation of the AsyncBlobFetcher.

Constructor Summary

Constructors

Constructor and Description
GrpcAsyncBlobFetcher(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, Protocol protocol, int casDeadline)

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<Unit>	batchFetchBlobs(com.google.common.collect.ImmutableMultimap<Protocol.Digest,Callable<WritableByteChannel>> requests, com.google.common.collect.ImmutableMultimap<Protocol.Digest,com.google.common.util.concurrent.SettableFuture<Unit>> futures)
com.google.common.util.concurrent.ListenableFuture<ByteBuffer>	fetch(Protocol.Digest digest)
com.google.common.util.concurrent.ListenableFuture<Unit>	fetchToStream(Protocol.Digest digest, WritableByteChannel channel)

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcAsyncBlobFetcher

public GrpcAsyncBlobFetcher(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,
                            Protocol protocol,
                            int casDeadline)

Method Detail

fetch

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

Specified by:

fetch in interface AsyncBlobFetcher

fetchToStream

public com.google.common.util.concurrent.ListenableFuture<Unit> fetchToStream(Protocol.Digest digest,
                                                                              WritableByteChannel channel)

Specified by:

fetchToStream in interface AsyncBlobFetcher

batchFetchBlobs

public com.google.common.util.concurrent.ListenableFuture<Unit> batchFetchBlobs(com.google.common.collect.ImmutableMultimap<Protocol.Digest,Callable<WritableByteChannel>> requests,
                                                                                com.google.common.collect.ImmutableMultimap<Protocol.Digest,com.google.common.util.concurrent.SettableFuture<Unit>> futures)

Specified by:

batchFetchBlobs in interface AsyncBlobFetcher