Module coordinator 

Coordinator node definitions for distributed processing.

Defines the coordinator role, responsibilities, and configuration for managing worker nodes and distributing tasks in a distributed stream processing system.

Structs

CoordinatorConfig

Configuration for a coordinator node.

WorkerInfo

Information about a registered worker.

Enums

CoordinatorError

Coordinator-related errors.

RebalanceStrategy

Strategy for rebalancing partitions when workers change.

Traits

Coordinator

Trait for coordinator nodes in distributed processing.