Enum dataflow_types::client::StorageCommand

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,
    },
}

Commands related to the ingress and egress of collections.

Variants

CreateSources(Vec<(GlobalId, (SourceDesc, Antichain<Timestamp>))>)

Tuple Fields

0: 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>)

Tuple Fields

0: Vec<GlobalId>

Drop the sources bound to these names.

Insert

Fields

id: GlobalId

Identifier of the local input.

updates: Vec<Update>

A list of updates to be introduced to the input.

Insert updates into the local input named id.

DurabilityFrontierUpdates(Vec<(GlobalId, Antichain<Timestamp>)>)

Tuple Fields

0: 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.

bindings: Vec<(PartitionId, Timestamp, MzOffset)>

Previously stored timestamp bindings.

Add a new source to be aware of for timestamping.

AllowSourceCompaction(Vec<(GlobalId, Antichain<Timestamp>)>)

Tuple Fields

0: 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

impl Clone for StorageCommand

fn clone(&self) -> StorageCommand

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StorageCommand

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StorageCommand

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl<'__enum_kinds1> From<&'__enum_kinds1 StorageCommand> for StorageCommandKind

fn from(_value: &'__enum_kinds1 StorageCommand) -> Self

Performs the conversion.

impl<'__enum_kinds1> From<StorageCommand> for StorageCommandKind

fn from(value: StorageCommand) -> Self

Performs the conversion.

impl Serialize for StorageCommand

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.