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

int

abstract assigned_standbys() → Set[faust.types.tuples.TP][source]
Return type

Set[TP]

abstract assigned_actives() → Set[faust.types.tuples.TP][source]
Return type

Set[TP]

abstract is_active(tp: faust.types.tuples.TP) → bool[source]
Return type

bool

abstract is_standby(tp: faust.types.tuples.TP) → bool[source]
Return type

bool

abstract key_store(topic: str, key: bytes) → yarl.URL[source]
Return type

URL

abstract table_metadata(topic: str) → MutableMapping[str, MutableMapping[str, List[int]]][source]
Return type

MutableMapping[str, MutableMapping[str, List[int]]]

abstract 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]
abstract is_leader() → bool[source]
Return type

bool