Trait fluvio_smartengine::SmartModuleInstance

pub trait SmartModuleInstance: Send + Sync + Debug {
    fn process(&mut self, input: SmartModuleInput) -> Result<SmartModuleOutput>;
    fn params(&self) -> SmartModuleExtraParams;
    fn mut_ctx(&mut self) -> &mut SmartModuleContext;
}

Required Methods

fn process(&mut self, input: SmartModuleInput) -> Result<SmartModuleOutput>

fn params(&self) -> SmartModuleExtraParams

fn mut_ctx(&mut self) -> &mut SmartModuleContext

Implementations

impl dyn SmartModuleInstance + '_

pub fn process_batch(
    &mut self,
    iter: &mut FileBatchIterator,
    max_bytes: usize,
    join_last_record: Option<&Record>
) -> Result<(Batch, Option<SmartModuleRuntimeError>), Error>

Implementors

impl SmartModuleInstance for SmartModuleAggregate

impl SmartModuleInstance for SmartModuleArrayMap

impl SmartModuleInstance for SmartModuleFilter

impl SmartModuleInstance for SmartModuleFilterMap

impl SmartModuleInstance for SmartModuleJoin

impl SmartModuleInstance for SmartModuleJoinStream

impl SmartModuleInstance for SmartModuleMap