Enum MetaCommands

pub(crate) enum MetaCommands {
    Pause,
    Resume,
    ClusterInfo,
    SourceSplitInfo {
        ignore_id: bool,
    },
    Reschedule {
        plan: Option<String>,
        revision: Option<u64>,
        from: Option<String>,
        dry_run: bool,
        resolve_no_shuffle: bool,
    },
    BackupMeta {
        remarks: Option<String>,
    },
    RestoreMeta {
        opts: RestoreOpts,
    },
    DeleteMetaSnapshots {
        snapshot_ids: Vec<u64>,
    },
    ListConnections,
    ListServingFragmentMapping,
    UnregisterWorkers {
        workers: Vec<String>,
        yes: bool,
        ignore_not_found: bool,
        check_fragment_occupied: bool,
    },
    ValidateSource {
        props: String,
    },
    GraphCheck {
        endpoint: String,
    },
}

Variants

Pause

pause the stream graph

Resume

resume the stream graph

ClusterInfo

get cluster info

SourceSplitInfo

get source split info

Fields

ignore_id: bool

Reschedule

Reschedule the actors in the stream graph

The format is fragment_id-[worker_id:count]+[worker_id:count] You can provide either decreased worker_ids only or increased only, but decreased should be preceded by added when both are provided.

For example, for plan 100-[1:1]+[4:1] the follow request will be generated:

{
    100: WorkerReschedule {
        increased_actor_count: { 1: 1 },
        decreased_actor_count: { 4: 1 },
    }
}

Use ; to separate multiple fragment

Fields

plan: Option<String>

Plan of reschedule, needs to be used with revision

revision: Option<u64>

Revision of the plan

from: Option<String>

Reschedule from a specific file

dry_run: bool

Show the plan only, no actual operation

resolve_no_shuffle: bool

Resolve NO_SHUFFLE upstream

BackupMeta

backup meta by taking a meta snapshot

Fields

remarks: Option<String>

RestoreMeta

restore meta by recovering from a meta snapshot

Fields

opts: RestoreOpts

DeleteMetaSnapshots

delete meta snapshots

Fields

snapshot_ids: Vec<u64>

ListConnections

List all existing connections in the catalog

ListServingFragmentMapping

List fragment mapping for serving

UnregisterWorkers

Unregister workers from the cluster

Fields

workers: Vec<String>

The workers that needs to be unregistered, worker_id and worker_host:worker_port are both supported

yes: bool

Automatic yes to prompts

ignore_not_found: bool

The worker not found will be ignored

check_fragment_occupied: bool

Checking whether the fragment is occupied by workers

ValidateSource

Validate source interface for the cloud team

Fields

props: String

With properties in json format If privatelink is used, specify connection.id instead of connection.name

GraphCheck

Performing graph check for scaling.

Fields

endpoint: String

SQL endpoint

Trait Implementations

impl FromArgMatches for MetaCommands

fn from_arg_matches(__clap_arg_matches: &ArgMatches) -> Result<Self, Error>

Instantiate Self from [ArgMatches], parsing the arguments as needed.

fn from_arg_matches_mut( __clap_arg_matches: &mut ArgMatches, ) -> Result<Self, Error>

Instantiate Self from [ArgMatches], parsing the arguments as needed.

fn update_from_arg_matches( &mut self, __clap_arg_matches: &ArgMatches, ) -> Result<(), Error>

Assign values from ArgMatches to self.

fn update_from_arg_matches_mut<'b>( &mut self, __clap_arg_matches: &mut ArgMatches, ) -> Result<(), Error>

Assign values from ArgMatches to self.

impl Subcommand for MetaCommands

fn augment_subcommands<'b>(__clap_app: Command) -> Command

Append to [Command] so it can instantiate Self.

fn augment_subcommands_for_update<'b>(__clap_app: Command) -> Command

Append to [Command] so it can update self.

fn has_subcommand(__clap_name: &str) -> bool

Test whether Self can parse a specific subcommand