com.facebook.buck.remoteexecution

Interface ContentAddressedStorageClient

All Known Implementing Classes:

GrpcContentAddressableStorageClient, LocalContentAddressedStorage

public interface ContentAddressedStorageClient

This is a simple ContentAddressedStorageClient interface used for remote execution.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ContentAddressedStorageClient.FileMaterializer Interface for filesystem operations required for materialization.

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.

Method Detail

addMissing

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

Throws:

IOException

materializeOutputs

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

Materializes the outputFiles and outputDirectories into root.

Throws:

IOException

containsDigest

boolean containsDigest(Protocol.Digest digest)

fetch

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