Module fluvio_smartmodule::dataplane::smartmodule

Re-exports

• pub use crate::SmartModuleRecord;

Structs

• Lookback
• SmartModuleAggregateInput
  A type to pass input to an Aggregate SmartModule WASM module
• SmartModuleAggregateOutput
  A type used to return processed records and/or an error from an Aggregate SmartModule
• SmartModuleExtraParams
• SmartModuleInitInput
  Input to SmartModule Init
• SmartModuleInitOutput
  A type used to return processed records and/or an error from a SmartModule
• SmartModuleInitRuntimeError
  A type used to capture and serialize errors from within a SmartModule
• SmartModuleInput
  A single SmartModule input record
• SmartModuleLookbackOutput
  A type used to return an error from a SmartModule Lookback
• SmartModuleLookbackRuntimeError
  A type used to capture and serialize errors from within a SmartModule
• SmartModuleOutput
  A type used to return processed records and/or an error from a SmartModule
• SmartModuleTransformRuntimeError
  A type used to capture and serialize errors from within a SmartModule

Enums

• LegacySmartModuleError
  Deprecated. A type representing the possible errors that may occur during DerivedStream execution.
• SmartModuleInitError
  Error during processing SmartModule initialization
• SmartModuleInitErrorStatus
• SmartModuleKind
• SmartModuleLookbackErrorStatus
• SmartModuleTransformErrorStatus
  Error during processing SmartModule transform error

Constants

• SMARTMODULE_TIMESTAMPS_VERSION
  SmartModule Version with support for Lookback with Age and Timestamps, LTA is the acronym for Lookback, Timestamps, and Age. This version is used for encoding and decoding SmartModuleInput