faust.types.stores
-
class
faust.types.stores.StoreT(url: Union[str, yarl.URL], app: faust.types.stores._AppT, table: faust.types.stores._CollectionT, *, 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, None] = '', value_serializer: Union[faust.types.codecs.CodecT, str, None] = '', options: Mapping[str, Any] = None, **kwargs: Any) → None[source]
-
abstract
persisted_offset(tp: faust.types.tuples.TP) → Optional[int][source]
- Return type
Optional[int]
-
abstract
set_persisted_offset(tp: faust.types.tuples.TP, offset: int) → None[source]
- Return type
None
-
abstract async
need_active_standby_for(tp: faust.types.tuples.TP) → bool[source]
- Return type
bool
-
abstract
apply_changelog_batch(batch: Iterable[faust.types.events.EventT], to_key: Callable[Any, KT], to_value: Callable[Any, VT]) → None[source]
- Return type
None
-
abstract
reset_state() → None[source]
- Return type
None
-
abstract async
on_rebalance(table: faust.types.stores._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
-
abstract async
on_recovery_completed(active_tps: Set[faust.types.tuples.TP], standby_tps: Set[faust.types.tuples.TP]) → None[source]
- Return type
None
