faust.stores.memory

In-memory table storage.

class faust.stores.memory.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

Table storage using an in-memory dictionary.

on_init() → 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

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

Return type:Optional[int]

reset_state() → None

Return type:None

logger = <Logger faust.stores.memory (WARNING)>