Enum dataflow_types::client::ComputeCommand

pub enum ComputeCommand {
    CreateInstance,
    DropInstance,
    CreateDataflows(Vec<DataflowDescription<Plan>>),
    DropSinks(Vec<GlobalId>),
    DropIndexes(Vec<GlobalId>),
    Peek {
        id: GlobalId,
        key: Option<Row>,
        conn_id: u32,
        timestamp: Timestamp,
        finishing: RowSetFinishing,
        map_filter_project: SafeMfpPlan,
    },
    CancelPeek {
        conn_id: u32,
    },
    AllowIndexCompaction(Vec<(GlobalId, Antichain<Timestamp>)>),
    EnableLogging(LoggingConfig),
}

Commands related to the computation and maintenance of views.

Variants

CreateInstance

Indicates the creation of an instance, and is the first command for its compute instance.

DropInstance

Indicates the termination of an instance, and is the last command for its compute instance.

CreateDataflows(Vec<DataflowDescription<Plan>>)

Tuple Fields

0: Vec<DataflowDescription<Plan>>

Create a sequence of dataflows.

Each of the dataflows must contain as_of members that are valid for each of the referenced arrangements, meaning AllowCompaction should be held back to those values until the command. Subsequent commands may arbitrarily compact the arrangements; the dataflow runners are responsible for ensuring that they can correctly maintain the dataflows.

DropSinks(Vec<GlobalId>)

Tuple Fields

0: Vec<GlobalId>

Drop the sinks bound to these names.

DropIndexes(Vec<GlobalId>)

Tuple Fields

0: Vec<GlobalId>

Drop the indexes bound to these namees.

Peek

Fields

id: GlobalId

The identifier of the arrangement.

key: Option<Row>

An optional key that should be used for the arrangement.

conn_id: u32

The identifier of this peek request.

Used in responses and cancelation requests.

timestamp: Timestamp

The logical timestamp at which the arrangement is queried.

finishing: RowSetFinishing

Actions to apply to the result set before returning them.

map_filter_project: SafeMfpPlan

Linear operation to apply in-line on each result.

Peek at an arrangement.

This request elicits data from the worker, by naming an arrangement and some actions to apply to the results before returning them.

The timestamp member must be valid for the arrangement that is referenced by id. This means that AllowCompaction for this arrangement should not pass timestamp before this command. Subsequent commands may arbitrarily compact the arrangements; the dataflow runners are responsible for ensuring that they can correctly answer the Peek.

CancelPeek

Fields

conn_id: u32

The identifier of the peek request to cancel.

Cancel the peek associated with the given conn_id.

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

Tuple Fields

0: Vec<(GlobalId, Antichain<Timestamp>)>

Enable compaction in views.

Each entry in the vector names a view and provides a frontier after which accumulations must be correct. The workers gain the liberty of compacting the corresponding maintained traces up through that frontier.

EnableLogging(LoggingConfig)

Tuple Fields

0: LoggingConfig

Request that the logging sources in the contained configuration are installed.

Trait Implementations

impl Clone for ComputeCommand

fn clone(&self) -> ComputeCommand

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ComputeCommand

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ComputeCommand

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 ComputeCommand> for ComputeCommandKind

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

Performs the conversion.

impl<'__enum_kinds1> From<ComputeCommand> for ComputeCommandKind

fn from(value: ComputeCommand) -> Self

Performs the conversion.

impl Serialize for ComputeCommand

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

Serialize this value into the given Serde serializer.