faust.stores.base

Base class for table storage drivers.

class faust.stores.base.Store(url: Union[str, yarl.URL], app: faust.types.app.AppT, *, table_name: str = '', key_type: Union[typing.Type[faust.types.models.ModelT], typing.Type[bytes], typing.Type[str]] = None, value_type: Union[typing.Type[faust.types.models.ModelT], typing.Type[bytes], typing.Type[str]] = None, key_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = 'json', value_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = 'json', **kwargs) → None[source]

Base class for table storage drivers.

persisted_offset(tp: faust.types.tuples.TP) → Union[int, NoneType][source]
Return type:Optional[int]
set_persisted_offset(tp: faust.types.tuples.TP, offset: int) → None[source]
Return type:None
label

Label used for graphs. :rtype: str

logger = <Logger faust.stores.base (WARNING)>
coroutine need_active_standby_for(self, tp: faust.types.tuples.TP) → bool[source]
Return type:bool
coroutine on_partitions_assigned(self, table: faust.types.tables.CollectionT, assigned: Set[faust.types.tuples.TP]) → None[source]
Return type:None
coroutine on_partitions_revoked(self, table: faust.types.tables.CollectionT, revoked: Set[faust.types.tuples.TP]) → None[source]
Return type:None
class faust.stores.base.SerializedStore(url: Union[str, yarl.URL], app: faust.types.app.AppT, *, table_name: str = '', key_type: Union[typing.Type[faust.types.models.ModelT], typing.Type[bytes], typing.Type[str]] = None, value_type: Union[typing.Type[faust.types.models.ModelT], typing.Type[bytes], typing.Type[str]] = None, key_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = 'json', value_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = 'json', **kwargs) → None[source]

Base class for table storage drivers requiring serialization.

apply_changelog_batch(batch: Iterable[faust.types.events.EventT], to_key: Callable[Any, Any], to_value: Callable[Any, Any]) → None[source]
Return type:None
keys() → collections.abc.KeysView[source]
Return type:KeysView
values() → collections.abc.ValuesView[source]
Return type:ValuesView
items() → collections.abc.ItemsView[source]
Return type:ItemsView
clear() → None[source]
Return type:None
logger = <Logger faust.stores.base (WARNING)>