cas

Documentation

Index

• func NewByteStreamServer(blobAccess blobstore.BlobAccess, readChunkSize int) bytestream.ByteStreamServer
• func NewContentAddressableStorageServer(contentAddressableStorage blobstore.BlobAccess) remoteexecution.ContentAddressableStorageServer
• type ContentAddressableStorage
  • func NewBlobAccessContentAddressableStorage(blobAccess blobstore.BlobAccess, maximumMessageSizeBytes uint64) ContentAddressableStorage

Functions

func NewByteStreamServer

func NewByteStreamServer(blobAccess blobstore.BlobAccess, readChunkSize int) bytestream.ByteStreamServer

NewByteStreamServer creates a GRPC service for reading blobs from and writing blobs to a BlobAccess. It is used by Bazel to access the Content Addressable Storage (CAS).

func NewContentAddressableStorageServer

func NewContentAddressableStorageServer(contentAddressableStorage blobstore.BlobAccess) remoteexecution.ContentAddressableStorageServer

NewContentAddressableStorageServer creates a GRPC service for serving the contents of a Bazel Content Addressable Storage (CAS) to Bazel.

Types

type ContentAddressableStorage

type ContentAddressableStorage interface {
	GetAction(ctx context.Context, digest *util.Digest) (*remoteexecution.Action, error)
	GetCommand(ctx context.Context, digest *util.Digest) (*remoteexecution.Command, error)
	GetDirectory(ctx context.Context, digest *util.Digest) (*remoteexecution.Directory, error)
	GetFile(ctx context.Context, digest *util.Digest, directory filesystem.Directory, name string, isExecutable bool) error
	GetTree(ctx context.Context, digest *util.Digest) (*remoteexecution.Tree, error)
	GetUncachedActionResult(ctx context.Context, digest *util.Digest) (*cas_proto.UncachedActionResult, error)

	PutFile(ctx context.Context, directory filesystem.Directory, name string, parentDigest *util.Digest) (*util.Digest, error)
	PutLog(ctx context.Context, log []byte, parentDigest *util.Digest) (*util.Digest, error)
	PutTree(ctx context.Context, tree *remoteexecution.Tree, parentDigest *util.Digest) (*util.Digest, error)
	PutUncachedActionResult(ctx context.Context, uncachedActionResult *cas_proto.UncachedActionResult, parentDigest *util.Digest) (*util.Digest, error)
}

ContentAddressableStorage provides typed access to a Bazel Content Addressable Storage (CAS).

func NewBlobAccessContentAddressableStorage

func NewBlobAccessContentAddressableStorage(blobAccess blobstore.BlobAccess, maximumMessageSizeBytes uint64) ContentAddressableStorage

NewBlobAccessContentAddressableStorage creates a ContentAddressableStorage that reads and writes Content Addressable Storage (CAS) objects from a BlobAccess based store.