Crate fukurow_streaming 

Fukurow Streaming

Real-time streaming processing for Fukurow reasoning engine. Supports Kafka, NATS, Redis Streams, and RabbitMQ.

Re-exports

pub use stream::StreamConfig;

pub use stream::StreamType;

pub use stream::AbstractStream;

pub use stream::StreamMessage;

pub use stream::StreamError;

pub use processor::StreamProcessor;

pub use processor::EventStreamProcessor;

pub use processor::EventSender;

pub use processor::StreamConsumer;

pub use processor::StreamProducer;

pub use consumer::*;

pub use producer::*;

pub use config::*;

Modules

config

Streaming Configuration

consumer

Stream Consumer

processor

Stream Processor

producer

Stream Producer

stream

Stream Abstraction

Enums

StreamingEvent

Streaming event types