Directories
¶
| Path | Synopsis |
|---|---|
|
Package backpressure implements credit-based flow control and adaptive rate limiting for the StreamForge processing pipeline.
|
Package backpressure implements credit-based flow control and adaptive rate limiting for the StreamForge processing pipeline. |
|
Package checkpoint implements the Chandy-Lamport distributed snapshot algorithm for consistent checkpointing of stream processing state.
|
Package checkpoint implements the Chandy-Lamport distributed snapshot algorithm for consistent checkpointing of stream processing state. |
|
Package observability provides metrics, tracing, and structured logging integration for StreamForge using OpenTelemetry and Prometheus.
|
Package observability provides metrics, tracing, and structured logging integration for StreamForge using OpenTelemetry and Prometheus. |
|
Package processor defines the Processor interface and core processor implementations (Map, Filter, FlatMap, Aggregate, Join, GroupBy) used in the StreamForge pipeline.
|
Package processor defines the Processor interface and core processor implementations (Map, Filter, FlatMap, Aggregate, Join, GroupBy) used in the StreamForge pipeline. |
|
Package record defines the core Record type used throughout the StreamForge framework.
|
Package record defines the core Record type used throughout the StreamForge framework. |
|
Package serde provides serialization/deserialization interfaces and implementations for StreamForge records.
|
Package serde provides serialization/deserialization interfaces and implementations for StreamForge records. |
|
Package sink defines the Sink interface and implementations for writing processed records out of the StreamForge pipeline.
|
Package sink defines the Sink interface and implementations for writing processed records out of the StreamForge pipeline. |
|
Package source defines the Source interface and implementations for reading records into the StreamForge processing pipeline.
|
Package source defines the Source interface and implementations for reading records into the StreamForge processing pipeline. |
|
Package state provides the StateStore interface and implementations for managing processor state.
|
Package state provides the StateStore interface and implementations for managing processor state. |
|
Package topology provides the fluent builder API for constructing stream processing topologies in StreamForge.
|
Package topology provides the fluent builder API for constructing stream processing topologies in StreamForge. |
|
Package window implements windowing strategies for stream processing: tumbling windows, sliding windows, and session windows.
|
Package window implements windowing strategies for stream processing: tumbling windows, sliding windows, and session windows. |
Click to show internal directories.
Click to hide internal directories.