Module mz_storage_client::client

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.

Structs

• PartitionedStorageState
  Maintained state for partitioned storage clients.
• ProtoAllowCompaction
• ProtoCompaction
• ProtoCreateSources
• ProtoFrontierUppersKind
• ProtoRunIngestionCommand
• ProtoRunSinkCommand
• ProtoRunSinks
• ProtoStorageCommand
• ProtoStorageResponse
• ProtoTrace
• RunIngestionCommand
  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.
• Update
  A batch of updates to be fed to a local input

Enums

• 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.

Traits

• StorageClient
  A client to a storage server.

Type Aliases

• StorageGrpcClient