faust.types.stores
-
class faust.types.stores.StoreT(url: Union[str, URL], app: _AppT, table: _CollectionT, *, table_name: str = '', key_type: Optional[_ModelArg] = None, value_type: Optional[_ModelArg] = None, key_serializer: Optional[Union[CodecT, str]] = '', value_serializer: Optional[Union[CodecT, str]] = '', options: Optional[Mapping[str, Any]] = None, **kwargs: Any)[source]
-
url: URL
-
app: _AppT
-
table: _CollectionT
-
table_name: str
-
key_type: Optional[_ModelArg]
-
value_type: Optional[_ModelArg]
-
key_serializer: Optional[Union[CodecT, str]]
-
value_serializer: Optional[Union[CodecT, str]]
-
options: Optional[Mapping[str, Any]]
-
abstract persisted_offset(tp: TP) → Optional[int][source]
- Return type:
_GenericAlias[int, None]
-
abstract set_persisted_offset(tp: TP, offset: int) → None[source]
- Return type:
None
-
abstract async need_active_standby_for(tp: TP) → bool[source]
- Return type:
bool
-
abstract apply_changelog_batch(batch: Iterable[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(assigned: Set[TP], revoked: Set[TP], newly_assigned: Set[TP], generation_id: int = 0) → None[source]
- Return type:
None
-
abstract async on_recovery_completed(active_tps: Set[TP], standby_tps: Set[TP]) → None[source]
- Return type:
None
-
abstract async backup_partition(tp: Union[TP, int], flush: bool = True, purge: bool = False, keep: int = 1) → None[source]
- Return type:
None
-
abstract restore_backup(tp: Union[TP, int], latest: bool = True, backup_id: int = 0) → None[source]
- Return type:
None
