faust.types.assignor

faust.types.assignor.TopicToPartitionMap

alias of typing.MutableMapping

faust.types.assignor.HostToPartitionMap

alias of typing.MutableMapping

class faust.types.assignor.PartitionAssignorT(app: faust.types.assignor.AppT, replicas: int = 0) → None[source]
assigned_standbys() → Set[faust.types.tuples.TP][source]
Return type:Set[TP]
assigned_actives() → Set[faust.types.tuples.TP][source]
Return type:Set[TP]
is_active(tp: faust.types.tuples.TP) → bool[source]
Return type:bool
is_standby(tp: faust.types.tuples.TP) → bool[source]
Return type:bool
key_store(topic: str, key: bytes) → yarl.URL[source]
Return type:URL
table_metadata(topic: str) → MutableMapping[str, MutableMapping[str, List[int]]][source]
Return type:MutableMapping[str, MutableMapping[str, List[int]]]
tables_metadata() → MutableMapping[str, MutableMapping[str, List[int]]][source]
Return type:MutableMapping[str, MutableMapping[str, List[int]]]
class faust.types.assignor.LeaderAssignorT(*, beacon: mode.utils.types.trees.NodeT = None, loop: asyncio.events.AbstractEventLoop = None) → None[source]
is_leader() → bool[source]
Return type:bool