Module client

Source
Expand description

The public API of the storage layer.

Structs§

PartitionedStorageState
Maintained state for partitioned storage clients.
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

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.
StorageResponse
Responses that the storage nature of a worker/dataflow can provide back to the coordinator.
TableData

Traits§

StorageClient
A client to a storage server.