Plexus.Expand.Queue (Plexus v0.1.0)

Copy Markdown View Source

Bounded, priority-ordered queue for expensive generative expansion.

Summary

Functions

cancel_actor(run_id, actor_id)
child_spec(init_arg)

Returns a specification to start this module under a supervisor.

start_link(opts)
submit(run_id, context, tag, spec, opts \\ [])

Functions

cancel_actor(run_id, actor_id)

@spec cancel_actor(term(), term()) :: :ok

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

start_link(opts)

submit(run_id, context, tag, spec, opts \\ [])

@spec submit(term(), map(), term(), term(), keyword()) :: :ok