faust.tables.objects

class faust.tables.objects.ChangeloggedObject(manager: faust.tables.objects.ChangeloggedObjectManager, key: Any) → None[source]
sync_from_storage(value: Any) → None[source]
Return type:None
as_stored_value() → Any[source]
Return type:Any
apply_changelog_event(operation: int, value: Any) → None[source]
Return type:None
class faust.tables.objects.ChangeloggedObjectManager(table: faust.tables.table.Table, **kwargs) → None[source]
send_changelog_event(key: Any, operation: int, value: Any) → None[source]
Return type:None
persisted_offset(tp: faust.types.tuples.TP) → Optional[int][source]
Return type:Optional[int]
set_persisted_offset(tp: faust.types.tuples.TP, offset: int) → None[source]
Return type:None
sync_from_storage() → None[source]
Return type:None
flush_to_storage() → None[source]
Return type:None
logger = <Logger faust.tables.objects (WARNING)>
coroutine on_rebalance(self, 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]
Return type:None
coroutine on_recovery_completed(self, active_tps: Set[faust.types.tuples.TP], standby_tps: 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
reset_state() → None[source]
Return type:None
storage
Return type:StoreT[~KT, ~VT]
apply_changelog_batch(batch: Iterable[faust.types.events.EventT], to_key: Callable[Any, Any], to_value: Callable[Any, Any]) → None[source]
Return type:None