faust.tables.objects
¶
Storing objects in tables.
This is also used to store data structures such as sets/lists.
-
class
faust.tables.objects.
ChangeloggedObject
(manager: faust.tables.objects.ChangeloggedObjectManager, key: Any) → None[source]¶ A changelogged object in a
ChangeloggedObjectManager
store.
-
class
faust.tables.objects.
ChangeloggedObjectManager
(table: faust.tables.table.Table, **kwargs: Any) → None[source]¶ Store of changelogged objects.
-
send_changelog_event
(key: Any, operation: int, value: Any) → None[source]¶ Send changelog event to the tables changelog topic.
- Return type
None
-
persisted_offset
(tp: faust.types.tuples.TP) → Optional[int][source]¶ Get the last persisted offset for changelog topic partition.
-
set_persisted_offset
(tp: faust.types.tuples.TP, offset: int) → None[source]¶ Set the last persisted offset for changelog topic partition.
- Return type
None
-
async
on_rebalance
(table: faust.types.tables.CollectionT, assigned: Set[faust.types.tuples.TP], revoked: Set[faust.types.tuples.TP], newly_assigned: Set[faust.types.tuples.TP]) → None[source]¶ Call when cluster is rebalancing.
- Return type
None
-
async
on_recovery_completed
(active_tps: Set[faust.types.tuples.TP], standby_tps: Set[faust.types.tuples.TP]) → None[source]¶ Call when table recovery is completed after rebalancing.
- Return type
None
-
logger
= <Logger faust.tables.objects (WARNING)>¶
-