faust.tables.changelogs

class faust.tables.changelogs.ChangelogReader(table: faust.types.tables.CollectionT, channel: faust.types.channels.ChannelT, app: faust.types.app.AppT, tps: Set[faust.types.tuples.TP], offsets: Counter[faust.types.tuples.TP] = None, stats_interval: Union[datetime.timedelta, float, str] = 5.0, **kwargs) → None[source]

Service synchronizing table state from changelog topic.

wait_for_shutdown = True
shutdown_timeout = None
recovered() → bool[source]
Return type:bool
logger = <Logger faust.tables.changelogs (WARNING)>
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
coroutine wait_done_reading(self) → None[source]
Return type:None
label

Label used for graphs. :rtype: str

shortlabel

Label used for logging. :rtype: str

coroutine faust.tables.changelogs.local_tps(table: faust.types.tables.CollectionT, tps: Iterable[faust.types.tuples.TP]) → Set[faust.types.tuples.TP][source]
Return type:Set[TP]
class faust.tables.changelogs.StandbyReader(table: faust.types.tables.CollectionT, channel: faust.types.channels.ChannelT, app: faust.types.app.AppT, tps: Set[faust.types.tuples.TP], offsets: Counter[faust.types.tuples.TP] = None, stats_interval: Union[datetime.timedelta, float, str] = 5.0, **kwargs) → None[source]

Service reading table changelogs to keep an up-to-date backup.

logger = <Logger faust.tables.changelogs (WARNING)>
recovered() → bool[source]
Return type:bool