Module functions 

Re-exports

pub use config::CompiledCustomInput;

pub use config::FunctionConfig;

pub use validation::ValidationConfig;

pub use validation::ValidationRule;

pub use map::MapConfig;

pub use map::MapMapping;

pub use parse::ParseConfig;

pub use publish::PublishConfig;

pub use filter::FilterConfig;

pub use filter::RejectAction;

pub use log::LogConfig;

pub use log::LogLevel;

pub use integration::EnrichConfig;

pub use integration::HttpCallConfig;

pub use integration::PublishKafkaConfig;

Modules

config

filter

integration

log

map

Map Function Module

parse

Parse Function Module

publish

Publish Function Module

validation

Validation Function Module

Traits

AsyncFunctionHandler

Async interface for task functions that operate on messages.

Type Aliases

BoxedFunctionHandler

Boxed handler stored in the engine’s function registry. Users construct these with Box::new(MyHandler) — the blanket impl above auto-coerces any AsyncFunctionHandler into Box<dyn DynAsyncFunctionHandler + Send + Sync>.