Struct IntervalSourceFactory 

pub struct IntervalSourceFactory { /* private fields */ }

Config-driven SourceFactory for IntervalPipe. spec carries the tick period in milliseconds; the inner handler and name are supplied by the caller building the factory instance (mirrors the request-factory boundary: the factory decides shape, the handler decides content).

Implementations

impl IntervalSourceFactory

pub fn new(name: impl Into<String>, inner: PipeHandle) -> Self

Register a thin factory that builds an IntervalPipe under name, dispatching every tick to inner.

Trait Implementations

impl Named for IntervalSourceFactory

fn name(&self) -> &str

the stable config key this factory is registered + selected under.

impl SourceFactory for IntervalSourceFactory

fn build(&self, spec: &Value) -> Result<SourceHandle, ProximaError>

Build a source from a config spec.