com.facebook.buck.remoteexecution

Interface AsyncBlobFetcher

All Known Implementing Classes:

GrpcAsyncBlobFetcher

public interface AsyncBlobFetcher

Interface used by OutputsMaterializer to fetch outputs from the CAS.

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)

Method Detail

fetch

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

fetchToStream

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

batchFetchBlobs

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)
                                                                  throws IOException

Throws:

IOException