Feline.Pipeline.Task (feline v0.1.0-rc.1)

Copy Markdown View Source

Orchestrates pipeline execution. Starts processors under a DynamicSupervisor, links them in order, sends StartFrame, and manages the lifecycle.

Summary

Functions

cancel(task)
child_spec(init_arg)

Returns a specification to start this module under a supervisor.

queue_frame(task, frame, direction \\ :downstream)
queue_frames(task, frames)
run(task)
start_link(pipeline, opts \\ [])
stop_when_done(task)

Functions

cancel(task)

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

queue_frame(task, frame, direction \\ :downstream)

queue_frames(task, frames)

run(task)

start_link(pipeline, opts \\ [])

stop_when_done(task)