faust.tables.recovery
¶
Table recovery after rebalancing.
-
exception
faust.tables.recovery.
RebalanceAgain
[source]¶ During rebalance, another rebalance happened.
-
class
faust.tables.recovery.
Recovery
(app: faust.types.app.AppT, tables: faust.types.tables.TableManagerT, **kwargs) → None[source]¶ Service responsible for recovering tables from changelog topics.
-
stats_interval
= 5.0¶
-
in_recovery
= False¶
-
standbys_pending
= False¶
-
signal_recovery_start
¶ - Return type
Event
-
signal_recovery_end
¶ - Return type
Event
-
signal_recovery_reset
¶ - Return type
Event
-
add_active
(table: faust.types.tables.CollectionT, tp: faust.types.tuples.TP) → None[source]¶ - Return type
None
-
add_standby
(table: faust.types.tables.CollectionT, tp: faust.types.tuples.TP) → None[source]¶ - Return type
None
-
standby_highwaters
= None¶ Standby highwaters by topic partition.
-
active_highwaters
= None¶ Active highwaters by topic partition.
-
logger
= <Logger faust.tables.recovery (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
-
highwaters
= None¶ Mapping of highwaters by topic partition.
-
tp_to_table
= None¶ Mapping from topic partition to table
-
active_tps
= None¶ Set of active topic partitions.
-
standby_tps
= None¶ Set of standby topic partitions.
-
active_offsets
= None¶ Active offset by topic partition.
-
standby_offsets
= None¶ Standby offset by topic partition.
-
buffers
= None¶ Changelog event buffers by table. These are filled by background task _slurp_changelog, and need to be flushed before starting new recovery/stopping.
-
buffer_sizes
= None¶ Cache of buffer size by topic partition..
-