Module distributed 

Distributed processing support. Distributed stream processing architecture.

This module defines the core architecture for distributed stream processing across multiple nodes. It provides the foundation for coordinator/worker patterns, communication protocols, state distribution, and fault tolerance.

Re-exports

pub use coordinator::Coordinator;

pub use coordinator::CoordinatorConfig;

pub use coordinator::CoordinatorError;

pub use partitioner::rebalance;

pub use partitioner::CustomPartitioner;

pub use partitioner::HashPartitioner;

pub use partitioner::PartitionKey;

pub use partitioner::PartitionStrategy;

pub use partitioner::Partitioner;

pub use partitioner::RangePartitioner;

pub use partitioner::RoundRobinPartitioner;

pub use protocol::Message;

pub use protocol::MessageType;

pub use protocol::ProtocolError;

pub use protocol::ProtocolVersion;

pub use worker::Worker;

pub use worker::WorkerConfig;

pub use worker::WorkerError;

pub use worker::WorkerId;

pub use worker::WorkerState;

Modules

coordinator

Coordinator node definitions for distributed processing.

fault_tolerance

Fault tolerance mechanisms for distributed processing.

network

Network communication layer for distributed processing.

partitioner

Data partitioning strategies for distributed processing.

protocol

Communication protocol for distributed stream processing.

worker

Worker node definitions for distributed processing.