Box.PoolProcessor.QueueBehaviour behaviour (box v0.15.1)

Summary

state()

watcher()

dequeue(state)

init(t)

load(state, t)

init(arg)

load(arg, state)

@type state() :: any()

@type watcher() :: pid()

@callback dequeue(state()) ::
  :empty | {Box.PoolProcessor.execute_function(), [watcher()], state()}

@callback enqueue(state(), Box.PoolProcessor.execute_function(), [watcher()]) :: state()

@callback init(Keyword.t()) :: {:ok, state()} | {:load, state()}

@callback load(state(), Keyword.t()) :: state()