Expand description
The public API of the storage layer.
Structs§
- Partitioned
Storage State - Maintained state for partitioned storage clients.
- RunIngestion
Command - A command that starts ingesting the given ingestion description
- RunOneshot
Ingestion - A command that starts ingesting the given ingestion description
- RunSink
Command - A command that starts exporting the given sink description
- Status
Update - A source or sink status update.
- Timestampless
Update - A batch of updates to be fed to a local input; however, the input must determine the most appropriate timestamps to use.
- Timestampless
Update Builder - 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§
- Append
Only Update - An update to an append only collection.
- Status
- A “kind” enum for statuses tracked by the health operator
- Storage
Command - Commands related to the ingress and egress of collections.
- Storage
Response - Responses that the storage nature of a worker/dataflow can provide back to the coordinator.
- Table
Data
Traits§
- Storage
Client - A client to a storage server.