This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.0.
Consumer Scheduling -
- class kombu.utils.scheduling.FairCycle(fun, resources, predicate=<class 'Exception'>)¶
Cycle between resources.
Consume from a set of resources, where each resource gets an equal chance to be consumed from.
fun (Callable) – Callback to call.
resources (Sequence[Any]) – List of resources.
predicate (type) – Exception predicate.
- get(callback, **kwargs)¶
Get from next resource.
- class kombu.utils.scheduling.priority_cycle(it=None)¶
Cycle that repeats items in order.
Unused in this implementation.
- class kombu.utils.scheduling.round_robin_cycle(it=None)¶
Iterator that cycles between items in round-robin.
Consume n items.
Move most recently used item to end of list.
Update items from iterable.