View Source Handoff.DistributedExecutor (Handoff v0.1.0)
Handles the distributed execution of functions across multiple nodes.
Provides node discovery, coordination, and remote task execution capabilities.
Link to this section Summary
Functions
Returns a specification to start this module under a supervisor.
Discovers and registers nodes in the cluster with their capabilities.
Executes the DAG across the distributed nodes.
Registers the local node with its capabilities and makes it available for function execution.
Link to this section Functions
Returns a specification to start this module under a supervisor.
See Supervisor.
Discovers and registers nodes in the cluster with their capabilities.
Makes remote calls to discover nodes and their resources.
Executes the DAG across the distributed nodes.
parameters
Parameters
- dag: A validated DAG to execute
- opts: Optional execution options
returns
Returns
{:ok, results}with a map of function IDs to results on success{:error, reason}on failure
Registers the local node with its capabilities and makes it available for function execution.
parameters
Parameters
- caps: Map of capabilities provided by this node (e.g., %{cpu: 8, memory: 4000})