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]
group_for_topic(topic: str) → int[source]
Return type

int

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