Kombu.Utils.Scheduling.FairCycle (Kombu v0.1.0)

Copy Markdown View Source

Cycle fairly between resources (kombu.utils.scheduling.FairCycle).

Summary

Types

t()

Functions

close(cycle)
get(cycle, callback, opts \\ [])
new(fun, resources, predicate \\ RuntimeError)
next_resource(cycle)

Types

t()

@type t() :: %Kombu.Utils.Scheduling.FairCycle{
  fun: function() | nil,
  pos: non_neg_integer(),
  predicate: module() | [module()],
  resources: list()
}

Functions

close(cycle)

get(cycle, callback, opts \\ [])

new(fun, resources, predicate \\ RuntimeError)

next_resource(cycle)