Module processor 

Typed Processor API and the type-erased execution graph used by the runtime.

Re-exports

pub use api::Processor;

pub use api::ProcessorContext;

pub use api::ProcessorSupplier;

pub use erased::ProcessorError;

pub use fixed_key::FixedKeyProcessor;

pub use fixed_key::FixedKeyProcessorContext;

pub use fixed_key::FixedKeyProcessorSupplier;

pub use fixed_key::FixedKeyRecord;

pub use punctuation::Cancellable;

pub use punctuation::PunctuationType;

pub use punctuation::Punctuator;

pub use record::Record;

pub use record::RecordContext;

pub use serde::BytesSerde;

pub use serde::Changed;

pub use serde::Consumed;

pub use serde::DefaultSerde;

pub use serde::I64Serde;

pub use serde::Produced;

pub use serde::Serde;

pub use serde::SerdeError;

pub use serde::SerdeRole;

pub use serde::StringSerde;

Modules

api

The typed Processor API: Processor, ProcessorSupplier, and the ProcessorContext users call forward on.

erased

Type-erased records, plus the per-dispatch context that the graph driver hands to each node.

fixed_key

Fixed-key Processor API (KIP-820 processValues).

punctuation

Punctuation through ProcessorContext::schedule in the KIP Processor API. These are periodic callbacks that fire on a stream-time or wall-clock boundary.

record

Record<K,V> and RecordContext, which flow through the processor graph.

schema_serde

Bridges krabka-schema-serde typed serdes into the Streams Serde<T> boundary, and implements the membership SchemaPrewarm hook for SchemaCache. The schema-serde feature gates this module.

serde

Serde<T>: typed (de)serialization at source/sink boundaries.