com.facebook.buck.remoteexecution.grpc

Class GrpcProtocol

java.lang.Object

com.facebook.buck.remoteexecution.grpc.GrpcProtocol

All Implemented Interfaces:

Protocol

public class GrpcProtocol
extends Object
implements Protocol

A Grpc-based Protocol implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GrpcProtocol.GrpcDigest Wrapped Grpc Digest.
static class	GrpcProtocol.GrpcOutputDirectory Wrapped Grpc OutputDirectory.
static class	GrpcProtocol.GrpcOutputFile Wrapped Grpc OutputFile.

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

Protocol.Action, Protocol.Command, Protocol.Digest, Protocol.Directory, Protocol.DirectoryNode, Protocol.FileNode, Protocol.OutputDirectory, Protocol.OutputFile, Protocol.SymlinkNode, Protocol.Tree, Protocol.TreeNode

Constructor Summary

Constructors

Constructor and Description
GrpcProtocol()

Method Summary

Modifier and Type	Method and Description
Protocol.Digest	computeDigest(byte[] data)
Protocol.Digest	computeDigest(Protocol.Directory directory)
static build.bazel.remote.execution.v2.Digest	get(Protocol.Digest blob)
static build.bazel.remote.execution.v2.Directory	get(Protocol.Directory directory)
static build.bazel.remote.execution.v2.OutputDirectory	get(Protocol.OutputDirectory outputDirectory)
static build.bazel.remote.execution.v2.OutputFile	get(Protocol.OutputFile outputFile)
com.google.common.hash.HashFunction	getHashFunction()
MessageDigest	getMessageDigest()
Protocol.Action	newAction(Protocol.Digest commandDigest, Protocol.Digest inputRootDigest)
Protocol.Command	newCommand(com.google.common.collect.ImmutableList<String> command, com.google.common.collect.ImmutableSortedMap<String,String> commandEnvironment, Set<Path> outputs, com.facebook.buck.remoteexecution.proto.WorkerRequirements workerRequirements)
Protocol.Digest	newDigest(String hash, int size)
Protocol.Directory	newDirectory(List<Protocol.DirectoryNode> directories, Collection<Protocol.FileNode> files, Collection<Protocol.SymlinkNode> symlinks)
Protocol.DirectoryNode	newDirectoryNode(String name, Protocol.Digest digest)
Protocol.FileNode	newFileNode(Protocol.Digest digest, String name, boolean isExecutable)
Protocol.OutputDirectory	newOutputDirectory(Path output, Protocol.Digest treeDigest)
Protocol.OutputFile	newOutputFile(Path output, Protocol.Digest digest, boolean isExecutable)
Protocol.SymlinkNode	newSymlinkNode(String name, Path target) Wrapped Grpc OutputFile.
Protocol.Tree	newTree(Protocol.Directory directory, List<Protocol.Directory> directories)
Protocol.Action	parseAction(ByteBuffer data)
Protocol.Command	parseCommand(ByteBuffer data)
Protocol.Directory	parseDirectory(ByteBuffer data)
Protocol.Tree	parseTree(ByteBuffer data)
byte[]	toByteArray(Protocol.Action action)
byte[]	toByteArray(Protocol.Command actionCommand)
byte[]	toByteArray(Protocol.Directory directory)
byte[]	toByteArray(Protocol.Tree tree)

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcProtocol

public GrpcProtocol()

Method Detail

parseCommand

public Protocol.Command parseCommand(ByteBuffer data)
                              throws IOException

Specified by:

parseCommand in interface Protocol

Throws:

IOException

parseAction

public Protocol.Action parseAction(ByteBuffer data)
                            throws IOException

Specified by:

parseAction in interface Protocol

Throws:

IOException

parseDirectory

public Protocol.Directory parseDirectory(ByteBuffer data)
                                  throws IOException

Specified by:

parseDirectory in interface Protocol

Throws:

IOException

parseTree

public Protocol.Tree parseTree(ByteBuffer data)
                        throws IOException

Specified by:

parseTree in interface Protocol

Throws:

IOException

computeDigest

public Protocol.Digest computeDigest(Protocol.Directory directory)

Specified by:

computeDigest in interface Protocol

newCommand

public Protocol.Command newCommand(com.google.common.collect.ImmutableList<String> command,
                                   com.google.common.collect.ImmutableSortedMap<String,String> commandEnvironment,
                                   Set<Path> outputs,
                                   com.facebook.buck.remoteexecution.proto.WorkerRequirements workerRequirements)

Specified by:

newCommand in interface Protocol

newAction

public Protocol.Action newAction(Protocol.Digest commandDigest,
                                 Protocol.Digest inputRootDigest)

Specified by:

newAction in interface Protocol

newSymlinkNode

public Protocol.SymlinkNode newSymlinkNode(String name,
                                           Path target)

Wrapped Grpc OutputFile.

Specified by:

newSymlinkNode in interface Protocol

newOutputDirectory

public Protocol.OutputDirectory newOutputDirectory(Path output,
                                                   Protocol.Digest treeDigest)

Specified by:

newOutputDirectory in interface Protocol

newTree

public Protocol.Tree newTree(Protocol.Directory directory,
                             List<Protocol.Directory> directories)

Specified by:

newTree in interface Protocol

newDirectoryNode

public Protocol.DirectoryNode newDirectoryNode(String name,
                                               Protocol.Digest digest)

Specified by:

newDirectoryNode in interface Protocol

newDirectory

public Protocol.Directory newDirectory(List<Protocol.DirectoryNode> directories,
                                       Collection<Protocol.FileNode> files,
                                       Collection<Protocol.SymlinkNode> symlinks)

Specified by:

newDirectory in interface Protocol

newDigest

public Protocol.Digest newDigest(String hash,
                                 int size)

Specified by:

newDigest in interface Protocol

newOutputFile

public Protocol.OutputFile newOutputFile(Path output,
                                         Protocol.Digest digest,
                                         boolean isExecutable)

Specified by:

newOutputFile in interface Protocol

newFileNode

public Protocol.FileNode newFileNode(Protocol.Digest digest,
                                     String name,
                                     boolean isExecutable)

Specified by:

newFileNode in interface Protocol

toByteArray

public byte[] toByteArray(Protocol.Directory directory)

Specified by:

toByteArray in interface Protocol

toByteArray

public byte[] toByteArray(Protocol.Tree tree)

Specified by:

toByteArray in interface Protocol

toByteArray

public byte[] toByteArray(Protocol.Command actionCommand)

Specified by:

toByteArray in interface Protocol

toByteArray

public byte[] toByteArray(Protocol.Action action)

Specified by:

toByteArray in interface Protocol

computeDigest

public Protocol.Digest computeDigest(byte[] data)

Specified by:

computeDigest in interface Protocol

getHashFunction

public com.google.common.hash.HashFunction getHashFunction()

Specified by:

getHashFunction in interface Protocol

getMessageDigest

public MessageDigest getMessageDigest()

Specified by:

getMessageDigest in interface Protocol

get

public static build.bazel.remote.execution.v2.Digest get(Protocol.Digest blob)

get

public static build.bazel.remote.execution.v2.OutputFile get(Protocol.OutputFile outputFile)

get

public static build.bazel.remote.execution.v2.OutputDirectory get(Protocol.OutputDirectory outputDirectory)

get

public static build.bazel.remote.execution.v2.Directory get(Protocol.Directory directory)