Continuum.Runtime.ActivityWorker.Dispatcher (continuum v0.5.0)

Copy Markdown View Source

Polls continuum_activity_tasks, leases available tasks, and starts workers.

Summary

Functions

Returns a specification to start this module under a supervisor.

Run one activity dispatch pass synchronously.

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

dispatch_once(opts \\ [])

@spec dispatch_once(keyword()) :: {:ok, non_neg_integer()} | {:error, term()}

Run one activity dispatch pass synchronously.