Module client

Expand description

The public API of the storage layer.

Modules§

proto_storage_client: Generated client implementations.
proto_storage_command: Nested message and enum types in ProtoStorageCommand.
proto_storage_response: Nested message and enum types in ProtoStorageResponse.
proto_storage_server: Generated server implementations.

PartitionedStorageState: Maintained state for partitioned storage clients.
ProtoCompaction
ProtoRunIngestionCommand
ProtoRunOneshotIngestion
ProtoRunSinkCommand
ProtoStorageCommand
ProtoStorageResponse
RunIngestionCommand: A command that starts ingesting the given ingestion description
RunOneshotIngestion: A command that starts ingesting the given ingestion description
RunSinkCommand: A command that starts exporting the given sink description
StatusUpdate: A source or sink status update.
TimestamplessUpdate: A batch of updates to be fed to a local input; however, the input must determine the most appropriate timestamps to use.
TimestamplessUpdateBuilder: A collection of timestamp-less updates. As updates are added to the builder they are automatically spilled to blob storage.
Update: A batch of updates to be fed to a local input

AppendOnlyUpdate: An update to an append only collection.
Status: A “kind” enum for statuses tracked by the health operator
StorageCommand: Commands related to the ingress and egress of collections.
StorageProtoServiceTypes
StorageResponse: Responses that the storage nature of a worker/dataflow can provide back to the coordinator.
TableData