Enum StreamingCommand 

pub enum StreamingCommand {
    List {
        detailed: bool,
    },
    Add {

        name: String,
        backend: String,
        events: Option<String>,
        queues: Option<String>,
        priorities: Option<String>,
        partitioning: Option<String>,
        format: String,
        buffer_size: usize,
        buffer_time: u64,
        include_payload: bool,
        kafka_brokers: Option<String>,
        kafka_topic: Option<String>,
        kinesis_region: Option<String>,
        kinesis_stream: Option<String>,
        kinesis_access_key: Option<String>,
        kinesis_secret_key: Option<String>,
        pubsub_project: Option<String>,
        pubsub_topic: Option<String>,
        pubsub_key_file: Option<String>,
    
},
    Remove {
        stream: String,
        confirm: bool,
    },
    Test {
        stream: String,
        event_type: String,
        job_id: Option<String>,
        queue: String,
    },
    Stats {
        stream: Option<String>,
        hours: u64,
    },
    Toggle {
        stream: String,
        enable: bool,
    },
    Update {
        stream: String,
        name: Option<String>,
        events: Option<String>,
        queues: Option<String>,
        priorities: Option<String>,
        partitioning: Option<String>,
        buffer_size: Option<usize>,
        buffer_time: Option<u64>,
    },
    Health {
        stream: Option<String>,
    },
}

Variants

List

Fields

detailed: bool

Add

Fields

name: String

backend: String

events: Option<String>

queues: Option<String>

priorities: Option<String>

partitioning: Option<String>

format: String

buffer_size: usize

buffer_time: u64

include_payload: bool

kafka_brokers: Option<String>

kafka_topic: Option<String>

kinesis_region: Option<String>

kinesis_stream: Option<String>

kinesis_access_key: Option<String>

kinesis_secret_key: Option<String>

pubsub_project: Option<String>

pubsub_topic: Option<String>

pubsub_key_file: Option<String>

Remove

Fields

stream: String

confirm: bool

Test

Fields

stream: String

event_type: String

job_id: Option<String>

queue: String

Stats

Fields

stream: Option<String>

hours: u64

Toggle

Fields

stream: String

enable: bool

Update

Fields

stream: String

name: Option<String>

events: Option<String>

queues: Option<String>

priorities: Option<String>

partitioning: Option<String>

buffer_size: Option<usize>

buffer_time: Option<u64>

Health

Fields

stream: Option<String>

Trait Implementations

impl Clone for StreamingCommand

fn clone(&self) -> StreamingCommand

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl FromArgMatches for StreamingCommand

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 StreamingCommand

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