View Source OPQ (OPQ: One Pooled Queue v4.0.4)

A simple, in-memory queue with worker pooling and rate limiting in Elixir.

Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

enqueue(feeder, event)

enqueue(feeder, mod, fun, args)

info(feeder)

init(opts \\ [])

Callback implementation for GenServer.init/1.

pause(feeder)

queue(feeder)

resume(feeder)

start_link(opts \\ [])

stop(feeder)

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

enqueue(feeder, event)

enqueue(feeder, mod, fun, args)

info(feeder)

init(opts \\ [])

Callback implementation for GenServer.init/1.

pause(feeder)

queue(feeder)

resume(feeder)

start_link(opts \\ [])

stop(feeder)