Module streaming 

Streaming framework for job events.

This module provides a framework for streaming events from running jobs:

• Stream types and messages
• Configurable filtering and deduplication
• Endpoint configuration for different job types
• Handlers for processing stream messages
• Job streamer for polling and dispatching

Re-exports

pub use config::StreamConfig;

pub use endpoints::StreamEndpoints;

pub use handler::BufferedHandler;

pub use handler::CallbackHandler;

pub use handler::FilteredHandler;

pub use handler::JsonHandler;

pub use handler::MultiHandler;

pub use handler::StreamHandler;

pub use streamer::JobStreamer;

pub use types::StreamMessage;

pub use types::StreamType;

Modules

config

Stream configuration for filtering and controlling stream behavior.

endpoints

Stream endpoint configuration for different job types.

handler

Stream handler trait and built-in handlers.

streamer

Job streamer for polling and streaming job events.

types

Streaming types for job event streams.