buildgrid.server.cas.instance module

Storage Instances

Instances of CAS and ByteStream

class buildgrid.server.cas.instance.ContentAddressableStorageInstance(storage: StorageABC, read_only: bool = False, tree_cache_size: int | None = None, tree_cache_ttl_minutes: float = 60, tree_cache_redis: RedisProvider | None = None)

Bases: Instance

SERVICE_NAME: ClassVar[str] = 'build.bazel.remote.execution.v2.ContentAddressableStorage'

The expected FULL_NAME of the Service which will wrap this instance. This value should be declared on the class of any Instance implementations.

start() → None

A method called when the grpc service is starting.

This method may be overriden if startup logic is required.

stop() → None

A method called when the grpc service is shutting down.

This method may be overriden if shutdown logic is required.

find_missing_blobs(blob_digests: Sequence[Digest]) → FindMissingBlobsResponse

batch_update_blobs(requests: Sequence[Request]) → BatchUpdateBlobsResponse

batch_read_blobs(digests: Sequence[Digest]) → BatchReadBlobsResponse

get_tree(request: GetTreeRequest) → Iterator[GetTreeResponse]

class buildgrid.server.cas.instance.WriteBlobState(hash: '_Hash', bytes_count: int)

Bases: object

hash: _Hash

bytes_count: int

update(data: bytes) → None

validate(digest: Digest) → None

class buildgrid.server.cas.instance.ByteStreamInstance(storage: StorageABC, read_only: bool = False, disable_overwrite_early_return: bool = False, stream_blob: bool = True)

Bases: Instance

SERVICE_NAME: ClassVar[str] = 'google.bytestream.ByteStream'

The expected FULL_NAME of the Service which will wrap this instance. This value should be declared on the class of any Instance implementations.

BLOCK_SIZE = 1048576

start() → None

A method called when the grpc service is starting.

This method may be overriden if startup logic is required.

stop() → None

A method called when the grpc service is shutting down.

This method may be overriden if shutdown logic is required.

read_cas_blob(digest: Digest, read_offset: int, read_limit: int) → Iterator[ReadResponse]

write_cas_blob(digest_hash: str, digest_size: str, requests: Iterator[WriteRequest]) → WriteResponse