Public entry point for the AttractorEx pipeline engine.
AttractorEx exposes the stable API for parsing, validating, executing, resuming,
and serving DOT-defined Attractor pipelines.
Main APIs
run/3executes a new pipelineresume/3resumes from a checkpointvalidate/2returns diagnostics without executionvalidate_or_raise/2escalates validation errorsstart_http_server/1exposes the engine over HTTP
Summary
Functions
Resumes execution from a checkpoint struct, map, or checkpoint.json path.
Parses, validates, and executes a pipeline graph from scratch.
Starts the lightweight Bandit-backed AttractorEx HTTP service.
Stops a previously started AttractorEx HTTP server.
Validates a DOT string or normalized graph and returns diagnostics.
Validates a DOT string or graph and raises on error-severity diagnostics.
Functions
@spec resume(String.t(), String.t() | map(), keyword()) :: {:ok, map()} | {:error, %{diagnostics: list()}} | {:error, %{error: String.t()}}
Resumes execution from a checkpoint struct, map, or checkpoint.json path.
@spec run(String.t(), map(), keyword()) :: {:ok, map()} | {:error, %{diagnostics: list()}} | {:error, %{error: String.t()}}
Parses, validates, and executes a pipeline graph from scratch.
Starts the lightweight Bandit-backed AttractorEx HTTP service.
Stops a previously started AttractorEx HTTP server.
@spec validate( String.t() | AttractorEx.Graph.t(), keyword() ) :: list() | {:error, %{error: String.t()}}
Validates a DOT string or normalized graph and returns diagnostics.
@spec validate_or_raise( String.t() | AttractorEx.Graph.t(), keyword() ) :: list()
Validates a DOT string or graph and raises on error-severity diagnostics.