faust.types.assignor

class faust.types.assignor.PartitionAssignorT(app: _AppT, replicas: int = 0)[source]
replicas: int
app: _AppT
abstract group_for_topic(topic: str) → int[source]
Return type:

int

abstract assigned_standbys() → Set[TP][source]
Return type:

_GenericAlias[TP]

abstract assigned_actives() → Set[TP][source]
Return type:

_GenericAlias[TP]

abstract is_active(tp: TP) → bool[source]
Return type:

bool

abstract is_standby(tp: TP) → bool[source]
Return type:

bool

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

URL

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

_GenericAlias[str, _GenericAlias[str, _GenericAlias[int]]]

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

_GenericAlias[str, _GenericAlias[str, _GenericAlias[int]]]

class faust.types.assignor.LeaderAssignorT(app: _AppT, **kwargs: Any)[source]
app: _AppT
abstract is_leader() → bool[source]
Return type:

bool