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.
Structs§
- Partitioned
Storage State - Maintained state for partitioned storage clients.
- Proto
Cancel Oneshot Ingestions Command - Proto
Compaction - Proto
Create Sources - Proto
RunIngestion Command - Proto
RunOneshot Ingestion - Proto
RunOneshot Ingestions Command - Proto
RunSink Command - Proto
Storage Command - Proto
Storage Response - 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
Proto Service Types - 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.