faust.types.stores

class faust.types.stores.StoreT(url: Union[str, yarl.URL], app: faust.types.stores.AppT, *, table_name: str = '', key_type: faust.types.stores.ModelArg = None, value_type: faust.types.stores.ModelArg = None, key_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = '', value_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = '', **kwargs) → None

persisted_offset(tp: faust.types.tuples.TP) → Union[int, NoneType]

Return type:Optional[int]

set_persisted_offset(tp: faust.types.tuples.TP, offset: int) → None

Return type:None

apply_changelog_batch(batch: Iterable[faust.types.events.EventT], to_key: Callable[Any, Any], to_value: Callable[Any, Any]) → None

Return type:None

reset_state() → None

Return type:None

coroutine need_active_standby_for(self, tp: faust.types.tuples.TP) → bool

Return type:bool

coroutine on_partitions_assigned(self, table: faust.types.stores.CollectionT, assigned: Set[faust.types.tuples.TP]) → None

Return type:None

coroutine on_partitions_revoked(self, table: faust.types.stores.CollectionT, revoked: Set[faust.types.tuples.TP]) → None

Return type:None