Expand description
Distributed processing for multi-node transformations Distributed processing for multi-node transformation pipelines
This module provides distributed computing capabilities for transformations across multiple nodes using async Rust and message passing.
Structs§
- Auto
Scaling Config - Auto-scaling configuration
- Circuit
Breaker - Circuit breaker for fault tolerance
- Cluster
Health Summary - Cluster health summary
- Distributed
Config - Configuration for distributed processing
- Distributed
Coordinator - Distributed transformation coordinator
- DistributedPCA
- Distributed PCA implementation
- Enhanced
Distributed Coordinator - Enhanced distributed coordinator with fault tolerance and auto-scaling
- Node
Health - Enhanced node health monitoring and status
- Node
Info - Information about a worker node
- Task
Result - Result of a distributed task
Enums§
- Distributed
Task - Represents a distributed transformation task
- Node
Status - Node status enumeration
- Partitioning
Strategy - Strategy for partitioning data across nodes