ASM.Store.Memory (ASM v0.9.2)

Copy Markdown View Source

In-memory event store with idempotent append by event id.

Summary

Types

event_queue()
t()

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

start_link(opts)

Types

event_queue()

@type event_queue() :: :queue.queue(ASM.Event.t())

t()

@type t() :: %ASM.Store.Memory{
  by_session: %{optional(String.t()) => event_queue()},
  by_session_event_ids: %{optional(String.t()) => MapSet.t(String.t())},
  seen_event_ids: MapSet.t(String.t())
}

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

start_link(opts)

@spec start_link(keyword()) :: GenServer.on_start()