Gust.Run.Dispatcher behaviour (gust v0.1.36)

Copy Markdown

Dispatch strategy used to enqueue runs and initialize claim delivery.

Configure an implementation with :run_dispatcher. Implementations own the transport-specific enqueue semantics and arrange for Gust.Run.Claimer to receive :claim_runs messages.

Summary

Callbacks

enqueue_all(list)

@callback enqueue_all([term()]) :: [term()]

setup()

@callback setup() :: :ok

Functions

enqueue(run)

enqueue_all(runs)

impl()

setup()