faust.tables.manager

Tables (changelog stream).

class faust.tables.manager.TableManager(app: faust.types.app.AppT, **kwargs) → None[source]

Manage tables used by Faust worker.

on_rebalance_start() → None[source]
Return type:None
on_actives_ready() → None[source]
Return type:None
on_standbys_ready() → None[source]
Return type:None
changelog_topics
Return type:Set[str]
changelog_queue
Return type:ThrowableQueue
logger = <Logger faust.tables.manager (WARNING)>
coroutine on_rebalance(self, assigned: Set[faust.types.tuples.TP], revoked: Set[faust.types.tuples.TP], newly_assigned: Set[faust.types.tuples.TP]) → None[source]
Return type:None
coroutine on_start(self) → None[source]

Called every time before the service is started/restarted.

Return type:None
coroutine on_stop(self) → None[source]

Called every time before the service is stopped/restarted.

Return type:None
recovery
Return type:Recovery[]
add(table: faust.types.tables.CollectionT) → faust.types.tables.CollectionT[source]
Return type:CollectionT[]
on_partitions_revoked(revoked: Set[faust.types.tuples.TP]) → None[source]
Return type:None