queuetopia

queuetopia v1.2.0 Queuetopia.Locks View Source

Link to this section Summary

Functions

lock_queue(repo, scope, queue, timeout)
release_expired_locks(repo, scope)
unlock_queue(repo, scope, queue)

Link to this section Functions

Link to this function

lock_queue(repo, scope, queue, timeout)

View Source

Specs

lock_queue(module(), binary(), binary(), integer()) ::
  {:error, :locked} | {:ok, Queuetopia.Locks.Lock.t()}
Link to this function

release_expired_locks(repo, scope)

View Source

Specs

release_expired_locks(module(), binary()) :: any()
Link to this function

unlock_queue(repo, scope, queue)

View Source

Specs

unlock_queue(module(), binary(), binary()) :: any()