Enum WorkerSubcommand

pub enum WorkerSubcommand {
    New {
        worker_name: WorkerNameArg,
        arguments: Vec<NewWorkerArgument>,
        env: Vec<(String, String)>,
    },
    Invoke {
        worker_name: WorkerNameArg,
        function_name: WorkerFunctionName,
        arguments: Vec<WorkerFunctionArgument>,
        enqueue: bool,
        idempotency_key: Option<IdempotencyKey>,
        stream: bool,
        stream_args: StreamArgs,
    },
    Get {
        worker_name: WorkerNameArg,
    },
    Delete {
        worker_name: WorkerNameArg,
    },
    List {
        component_name: ComponentOptionalComponentName,
        filter: Vec<String>,
        scan_cursor: Option<ScanCursor>,
        max_count: Option<u64>,
        precise: bool,
    },
    Stream {
        worker_name: WorkerNameArg,
        stream_args: StreamArgs,
    },
    Update {
        worker_name: WorkerNameArg,
        mode: Option<WorkerUpdateMode>,
        target_version: Option<u64>,
    },
    Interrupt {
        worker_name: WorkerNameArg,
    },
    Resume {
        worker_name: WorkerNameArg,
    },
    SimulateCrash {
        worker_name: WorkerNameArg,
    },
    Oplog {
        worker_name: WorkerNameArg,
        from: Option<u64>,
        query: Option<String>,
    },
    Revert {
        worker_name: WorkerNameArg,
        last_oplog_index: Option<u64>,
        number_of_invocations: Option<u64>,
    },
    CancelInvocation {
        worker_name: WorkerNameArg,
        idempotency_key: IdempotencyKey,
    },
}

Variants

New

Create new worker

Fields

worker_name: WorkerNameArg

arguments: Vec<NewWorkerArgument>

Worker arguments

env: Vec<(String, String)>

Worker environment variables

Invoke

Invoke (or enqueue invocation for) worker

Fields

worker_name: WorkerNameArg

function_name: WorkerFunctionName

Worker function name to invoke

arguments: Vec<WorkerFunctionArgument>

Worker function arguments in WAVE format

enqueue: bool

Enqueue invocation, and do not wait for it

idempotency_key: Option<IdempotencyKey>

Set idempotency key for the call, use “-” for auto generated key

stream: bool

Connect to the worker before invoke (the worker must already exist) and live stream its standard output, error and log channels

stream_args: StreamArgs

Get

Get worker metadata

Fields

worker_name: WorkerNameArg

Delete

Deletes a worker

Fields

worker_name: WorkerNameArg

List

List worker metadata

Fields

component_name: ComponentOptionalComponentName

filter: Vec<String>

Filter for worker metadata in form of property op value.

Filter examples: name = worker-name, version >= 0, status = Running, env.var1 = value. Can be used multiple times (AND condition is applied between them)

scan_cursor: Option<ScanCursor>

Cursor position, if not provided, starts from the beginning.

Cursor can be used to get the next page of results, use the cursor returned in the previous response. The cursor has the format ‘layer/position’ where both layer and position are numbers.

max_count: Option<u64>

The maximum the number of returned workers, returns all values is not specified. When multiple component is selected, then the limit it is applied separately

precise: bool

When set to true it queries for most up-to-date status for each worker, default is false

Stream

Connect to a worker and live stream its standard output, error and log channels

Fields

worker_name: WorkerNameArg

stream_args: StreamArgs

Update

Updates a worker

Fields

worker_name: WorkerNameArg

mode: Option<WorkerUpdateMode>

Update mode - auto or manual (default is auto)

target_version: Option<u64>

The new version of the updated worker (default is the latest version)

Interrupt

Interrupts a running worker

Fields

worker_name: WorkerNameArg

Resume

Resume an interrupted worker

Fields

worker_name: WorkerNameArg

SimulateCrash

Simulates a crash on a worker for testing purposes.

The worker starts recovering and resuming immediately.

Fields

worker_name: WorkerNameArg

Oplog

Queries and dumps a worker’s full oplog

Fields

worker_name: WorkerNameArg

from: Option<u64>

Index of the first oplog entry to get. If missing, the whole oplog is returned

query: Option<String>

Lucene query to look for oplog entries. If missing, the whole oplog is returned

Revert

Reverts a worker by undoing its last recorded operations

Fields

worker_name: WorkerNameArg

last_oplog_index: Option<u64>

Revert by oplog index

number_of_invocations: Option<u64>

Revert by number of invocations

CancelInvocation

Cancels an enqueued invocation if it has not started yet

Fields

worker_name: WorkerNameArg

idempotency_key: IdempotencyKey

Idempotency key of the invocation to be cancelled

Trait Implementations

impl Debug for WorkerSubcommand

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

Formats the value using the given formatter.

impl FromArgMatches for WorkerSubcommand

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 WorkerSubcommand

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

Append to Command so it can instantiate Self via FromArgMatches::from_arg_matches_mut

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

Append to Command so it can instantiate self via FromArgMatches::update_from_arg_matches_mut

fn has_subcommand(__clap_name: &str) -> bool

Test whether Self can parse a specific subcommand