cas

package
v0.0.0-...-938d447 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 5, 2019 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL