Plexus.Record (Plexus v0.1.0)

Copy Markdown View Source

Append-only run event log plus a fixed-response replay store.

Summary

Functions

append(run_id, type, data \\ %{})

@spec append(term(), atom() | tuple(), map()) :: non_neg_integer()

events(run_id)

@spec events(term()) :: [map()]

load_replay(run_id, entries)

@spec load_replay(term(), Enumerable.t()) :: :ok

replay_entries(run_id)

@spec replay_entries(term()) :: [{String.t(), term()}]

replay_fetch(run_id, key)

@spec replay_fetch(term(), String.t()) :: {:ok, term()} | :error

replay_put(run_id, key, value)

@spec replay_put(term(), String.t(), term()) :: :ok