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:

_UnionGenericAlias[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