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

• CreateSinkCommand
  A command that starts exporting the given sink description
• CreateSourceCommand
  A command that starts ingesting the given ingestion description
• PartitionedStorageState
  Maintained state for partitioned storage clients.
• ProtoAllowCompaction
• ProtoCompaction
• ProtoCreateSinkCommand
• ProtoCreateSinks
• ProtoCreateSourceCommand
• ProtoCreateSources
• ProtoFrontierUppersKind
• ProtoStorageCommand
• ProtoStorageResponse
• ProtoTrace
• SinkStatisticsUpdate
• SourceStatisticsUpdate
• 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
• __FieldVisitor 🔒
• __FieldVisitor 🔒
• __FieldVisitor 🔒
• __FieldVisitor 🔒
• __FieldVisitor 🔒
• __FieldVisitor 🔒
• __FieldVisitor 🔒
• __FieldVisitor 🔒
• __FieldVisitor 🔒
• __Visitor 🔒
• __Visitor 🔒
• __Visitor 🔒
• __Visitor 🔒
• __Visitor 🔒
• __Visitor 🔒
• __Visitor 🔒
• __Visitor 🔒
• __Visitor 🔒
• __Visitor 🔒

Enums

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

Constants

• FIELDS 🔒
• FIELDS 🔒
• FIELDS 🔒
• FIELDS 🔒
• FIELDS 🔒
• FIELDS 🔒
• FIELDS 🔒
• STRUCT_NAME 🔒
• STRUCT_NAME 🔒
• STRUCT_NAME 🔒
• STRUCT_NAME 🔒
• STRUCT_NAME 🔒
• STRUCT_NAME 🔒
• STRUCT_NAME 🔒
• STRUCT_NAME 🔒
• STRUCT_NAME 🔒
• STRUCT_NAME 🔒
• VARIANTS 🔒
• VARIANTS 🔒

Traits

• PackableStats
  A trait that abstracts over user-facing statistics objects, used by spawn_statistics_scraper.
• StorageClient
  A client to a storage server.

Type Definitions

• StorageGrpcClient