AttractorExPhx (attractor_phoenix v0.1.0)

Phoenix-facing adapter layer for AttractorEx.

AttractorEx remains the standalone pipeline engine. AttractorExPhx is the integration seam a Phoenix application can depend on for:

direct pipeline execution via run/3
supervision-friendly HTTP server startup via child_spec/1 and start_link/1
Req-based access to the HTTP control plane via AttractorExPhx.Client
PubSub subscriptions for LiveViews and other Phoenix processes via AttractorExPhx.PubSub

Summary

Functions

answer_pipeline_question(id, question_id, answer)

See AttractorExPhx.Client.answer_pipeline_question/3.

answer_question(id, question_id, answer)

See AttractorExPhx.Client.answer_question/3.

cancel_pipeline(id)

See AttractorExPhx.Client.cancel_pipeline/1.

child_spec(opts)

create_pipeline(dot, context, opts \\ [])

See AttractorExPhx.Client.create_pipeline/3.

get_pipeline(id)

See AttractorExPhx.Client.get_pipeline/1.

get_pipeline_checkpoint(id)

See AttractorExPhx.Client.get_pipeline_checkpoint/1.

get_pipeline_context(id)

See AttractorExPhx.Client.get_pipeline_context/1.

get_pipeline_events(id)

See AttractorExPhx.Client.get_pipeline_events/1.

get_pipeline_graph(id, format)

See AttractorExPhx.Client.get_pipeline_graph/2.

get_pipeline_graph_dot(id)

See AttractorExPhx.Client.get_pipeline_graph_dot/1.

get_pipeline_graph_json(id)

See AttractorExPhx.Client.get_pipeline_graph_json/1.

get_pipeline_graph_mermaid(id)

See AttractorExPhx.Client.get_pipeline_graph_mermaid/1.

get_pipeline_graph_svg(id)

See AttractorExPhx.Client.get_pipeline_graph_svg/1.

get_pipeline_graph_text(id)

See AttractorExPhx.Client.get_pipeline_graph_text/1.

get_pipeline_questions(id)

See AttractorExPhx.Client.get_pipeline_questions/1.

get_status(id)

See AttractorExPhx.Client.get_status/1.

list_pipelines()

See AttractorExPhx.Client.list_pipelines/0.

pipeline_topic(pipeline_id)

See AttractorExPhx.PubSub.topic/1.

run(dot, context \\ %{}, opts \\ [])

run_pipeline(dot, context, opts \\ [])

See AttractorExPhx.Client.run_pipeline/3.

start_http_server(opts \\ [])

start_link(opts \\ [])

stop_http_server(server)

subscribe_pipeline(pipeline_id, opts \\ [])

See AttractorExPhx.PubSub.subscribe_pipeline/2.

unsubscribe_pipeline(pipeline_id, opts \\ [])

See AttractorExPhx.PubSub.unsubscribe_pipeline/2.