Struct fluvio_connectors_common::opt::CommonSmartModuleOpt

pub struct CommonSmartModuleOpt {
    pub filter: Option<String>,
    pub filter_map: Option<String>,
    pub map: Option<String>,
    pub array_map: Option<String>,
    pub aggregate: Option<String>,
    pub aggregate_initial_value: Option<String>,
    pub smart_module: Option<String>,
    pub smartmodule_parameters: Option<Vec<(String, String)>>,
}

Fields

filter: Option<String>

Path of filter smartmodule used as a pre-produce step if using source connector. If using sink connector this smartmodule will be used in consumer.

If the value is not a path to a file, it will be used to lookup a SmartModule by name

filter_map: Option<String>

Path of filter_map smartmodule used as a pre-produce step if using source connector. If using sink connector this smartmodule will be used in consumer.

If the value is not a path to a file, it will be used to lookup a SmartModule by name

map: Option<String>

Path of map smartmodule used as a pre-produce step if using source connector. If using sink connector this smartmodule will be used in consumer.

If the value is not a path to a file, it will be used to lookup a SmartModule by name

array_map: Option<String>

Path of arraymap smartmodule used as a pre-produce step if using source connector. If using sink connector this smartmodule will be used in consumer.

If the value is not a path to a file, it will be used to lookup a SmartModule by name

aggregate: Option<String>

Path of aggregate smartmodule used as a pre-produce step if using source connector. If using sink connector this smartmodule will be used in consumer.

If the value is not a path to a file, it will be used to lookup a SmartModule by name

aggregate_initial_value: Option<String>

smart_module: Option<String>

Path of smartmodule used as a pre-produce step if using source connector. If using sink connector this smartmodule will be used in consumer.

If the value is not a path to a file, it will be used to lookup a SmartModule by name

smartmodule_parameters: Option<Vec<(String, String)>>

(Optional) Extra input parameters passed to the smartmodule module. They should be passed using key:value format.

It only accepts one key:value pair. In order to pass multiple pairs, call this option multiple times.

Example: –smartmodule-parameters key1:value –smartmodule-parameters key2:value

Trait Implementations

impl Clone for CommonSmartModuleOpt

fn clone(&self) -> CommonSmartModuleOpt

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for CommonSmartModuleOpt

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

Formats the value using the given formatter.

impl Default for CommonSmartModuleOpt

fn default() -> CommonSmartModuleOpt

Returns the “default value” for a type.

impl JsonSchema for CommonSmartModuleOpt

fn schema_name() -> String

The name of the generated JSON Schema.

fn json_schema(gen: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn is_referenceable() -> bool

Whether JSON Schemas generated for this type should be re-used where possible using the $ref keyword.

impl StructOpt for CommonSmartModuleOpt

fn clap<'a, 'b>() -> App<'a, 'b>

Returns clap::App corresponding to the struct.

fn from_clap(matches: &ArgMatches<'_>) -> Self

Builds the struct from clap::ArgMatches. It’s guaranteed to succeed if matches originates from an App generated by StructOpt::clap called on the same type, otherwise it must panic.

fn from_args() -> Self

Builds the struct from the command line arguments (std::env::args_os). Calls clap::Error::exit on failure, printing the error message and aborting the program.

fn from_args_safe() -> Result<Self, Error>

Builds the struct from the command line arguments (std::env::args_os). Unlike StructOpt::from_args, returns clap::Error on failure instead of aborting the program, so calling .exit is up to you.

fn from_iter<I>(iter: I) -> Self where
    I: IntoIterator,
    <I as IntoIterator>::Item: Into<OsString>,
    <I as IntoIterator>::Item: Clone, 

Gets the struct from any iterator such as a Vec of your making. Print the error message and quit the program in case of failure.

fn from_iter_safe<I>(iter: I) -> Result<Self, Error> where
    I: IntoIterator,
    <I as IntoIterator>::Item: Into<OsString>,
    <I as IntoIterator>::Item: Clone, 

Gets the struct from any iterator such as a Vec of your making.