Kombu.Common.QoS (Kombu v0.1.0)

Copy Markdown View Source

Process-safe manager for incrementing/decrementing a channel's prefetch_count (kombu.common.QoS).

Summary

Types

t()

Functions

decrement_eventually(qo_s, n \\ 1)
increment_eventually(qo_s, n \\ 1)
new(callback, initial_value, opts \\ [])
prev(qo_s)
set(qo_s, pcount)
update(qos)
value(qo_s)

Types

t()

@type t() :: %Kombu.Common.QoS{
  callback: term(),
  max_prefetch: term(),
  pid: term(),
  prev: term(),
  value: term()
}

Functions

decrement_eventually(qo_s, n \\ 1)

increment_eventually(qo_s, n \\ 1)

new(callback, initial_value, opts \\ [])

prev(qo_s)

set(qo_s, pcount)

update(qos)

value(qo_s)