Enum mz_sql::plan::SourceSinkClusterConfig

pub enum SourceSinkClusterConfig {
    Existing {
        id: ClusterId,
    },
    Linked {
        size: String,
    },
    Undefined,
}

Specifies the cluster for a source or a sink.

Variants

Existing

Fields

id: ClusterId

The ID of the cluster to use.

Use an existing cluster.

Linked

Fields

size: String

The size of the replica to create in the linked cluster.

Create a new linked storage cluster of the specified size.

NOTE(benesch): in the future, we hope to remove the concept of a linked cluster, and always associate sources and sinks with an existing cluster.

Undefined

The user did not specify a cluster behavior, so the actual behavior depends on the context. For sources the behavior depends on the data source:

• Ingestion: Use the default behavior.
• Source: Use the same cluster as the data source source.
• Progress: Use the same cluster as the non-progress source.
• Webhook: Does not allow undefined configs.

For sinks, always use the default behavior.

NOTE(benesch): we plan to remove this variant in the future by having the planner bind a source or sink with no SIZE or IN CLUSTER option to the active cluster. This behavior won’t be ergonomic until we have multipurpose clusters though.

Implementations

impl SourceSinkClusterConfig

pub fn cluster_id(&self) -> Option<&ClusterId>

Returns the ID of the cluster that this source/sink will be created on, if one exists.

Trait Implementations

impl Clone for SourceSinkClusterConfig

fn clone(&self) -> SourceSinkClusterConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SourceSinkClusterConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SourceSinkClusterConfig

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

Deserialize this value from the given Serde deserializer.

impl Serialize for SourceSinkClusterConfig

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

Serialize this value into the given Serde serializer.