edri.events.edri.store package

Submodules

edri.events.edri.store.compare_and_set module

class edri.events.edri.store.compare_and_set.CompareAndSet(name: str, expected: Any, value: Any, ttl: float | None = None)

Bases: Store

ttl: float | None = None

edri.events.edri.store.delete module

class edri.events.edri.store.delete.Delete(name: str)

Bases: Store

edri.events.edri.store.get module

class edri.events.edri.store.get.Get(name: str, data: edri.dataclass.event.Event | None = None)

Bases: Store

data: Event | None = None

edri.events.edri.store.get_callback module

class edri.events.edri.store.get_callback.GetCallback(name: str, condition: Callable[[Any], bool] | None = None)

Bases: Store

condition: Callable[[Any], bool] | None = None

edri.events.edri.store.increment module

class edri.events.edri.store.increment.Increment(name: str, amount: int | float = 1, ttl: float | None = None)

Bases: Store

amount: int | float = 1

ttl: float | None = None

edri.events.edri.store.set module

class edri.events.edri.store.set.Set(name: str, value: Any, ttl: float | None = None)

Bases: Store

ttl: float | None = None

edri.events.edri.store.set_if_absent module

class edri.events.edri.store.set_if_absent.SetIfAbsent(name: str, value: Any, ttl: float | None = None)

Bases: Store

ttl: float | None = None

edri.events.edri.store.store_purge module

class edri.events.edri.store.store_purge.StorePurge

Bases: Store

Sweep and drop all expired keys. Fire-and-forget; schedule it periodically (e.g. via the Scheduler) to reclaim memory held by expired-but-never-read keys.

Module contents