Enum dataflow_types::client::StorageCommand [−][src]
pub enum StorageCommand {
CreateSources(Vec<(GlobalId, (SourceDesc, Antichain<Timestamp>))>),
DropSources(Vec<GlobalId>),
Insert {
id: GlobalId,
updates: Vec<Update>,
},
DurabilityFrontierUpdates(Vec<(GlobalId, Antichain<Timestamp>)>),
AddSourceTimestamping {
id: GlobalId,
connector: SourceConnector,
bindings: Vec<(PartitionId, Timestamp, MzOffset)>,
},
AllowSourceCompaction(Vec<(GlobalId, Antichain<Timestamp>)>),
DropSourceTimestamping {
id: GlobalId,
},
AdvanceAllLocalInputs {
advance_to: Timestamp,
},
}
Expand description
Commands related to the ingress and egress of collections.
Variants
CreateSources(Vec<(GlobalId, (SourceDesc, Antichain<Timestamp>))>)
Create the enumerated sources, each associated with its identifier.
For each identifier, there is a source description and a valid since
frontier.
DropSources(Vec<GlobalId>)
Drop the sources bound to these names.
Insert
Fields
id: GlobalId
Identifier of the local input.
Insert updates
into the local input named id
.
DurabilityFrontierUpdates(Vec<(GlobalId, Antichain<Timestamp>)>)
Update durability information for sources.
Each entry names a source and provides a frontier before which the source can be exactly replayed across restarts (i.e. we can assign the same timestamps to all the same data)
AddSourceTimestamping
Fields
id: GlobalId
The ID of the timestamped source
connector: SourceConnector
The connector for the timestamped source.
Add a new source to be aware of for timestamping.
AllowSourceCompaction(Vec<(GlobalId, Antichain<Timestamp>)>)
Enable compaction in sources.
Each entry in the vector names a source and provides a frontier after which accumulations must be correct.
DropSourceTimestamping
Fields
id: GlobalId
The ID id of the formerly timestamped source.
Drop all timestamping info for a source
AdvanceAllLocalInputs
Fields
advance_to: Timestamp
The timestamp to advance to.
Advance all local inputs to the given timestamp.
Trait Implementations
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Performs the conversion.
Performs the conversion.
Auto Trait Implementations
impl RefUnwindSafe for StorageCommand
impl Send for StorageCommand
impl Sync for StorageCommand
impl Unpin for StorageCommand
impl UnwindSafe for StorageCommand
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more