Module distributed 

Distributed computing support for time series processing

This module provides infrastructure for distributing time series computations across multiple nodes, supporting both synchronous and asynchronous processing.

Structs

ClusterConfig

Configuration for distributed computing cluster

ClusterStatus

Cluster status information

DistributedProcessor

Distributed time series processor

DistributedTask

Task definition for distributed execution

FaultToleranceConfig

Fault tolerance configuration

NodeInfo

Node information in the cluster

TaskMetrics

Metrics for task execution

TaskResult

Result of a distributed task execution

Enums

LoadBalancingStrategy

Load balancing strategies for task distribution

NodeStatus

Node status in the cluster

TaskPriority

Task priority levels

TaskStatus

Task execution status

TaskType

Types of tasks that can be executed in distributed manner

Functions

distributed_moving_average

Convenience functions for common distributed operations