Module distributed 

Distributed Stream Processing

Provides infrastructure for coordinating stream processing across multiple nodes in a cluster. This module implements consistent hashing for partition routing, distributed window aggregation, and cluster-wide job distribution.

Components

• DistributedStreamTopology: Coordinates stream processing across nodes
• ConsistentHashRouter: Routes stream partitions to nodes via consistent hashing
• DistributedWindowAggregator: Aggregates windowed results across cluster nodes
• ClusterStreamCoordinator: Manages stream job distribution across the cluster

Structs

AggregatedWindowResult

Aggregated result across all nodes for a window

ClusterStreamCoordinator

Manages stream job distribution across a cluster.

ConsistentHashRouter

Routes stream partitions to nodes using consistent hashing.

CoordinatorStats

Statistics for the cluster coordinator

DistributedStreamTopology

Coordinates stream processing across multiple cluster nodes.

DistributedWindowAggregator

Aggregates windowed results from multiple cluster nodes.

PartialWindowResult

A partial window result from a single node

StreamJob

A stream processing job that is distributed across cluster nodes

StreamNode

Metadata for a node participating in distributed stream processing

TopologyConfig

Configuration for a distributed stream topology

TopologyStats

Statistics snapshot for the topology

Enums

DistributedStreamError

Errors that can occur in distributed stream processing

NodeStatus

Represents the health status of a cluster node

TopologyChange

A topology change event broadcast on topology changes

Type Aliases

DistributedResult

Result type for distributed stream operations