WorkflowStem.EventLog (workflow_stem v0.3.0)

Copy Markdown View Source

Append-then-publish event log facade for observable executions.

Durability belongs to the host adapter. The facade gives the runner one stable contract: append the canonical event first, then publish the persisted event for live subscribers. Late subscribers replay through the same adapter.

Summary

Types

event()

Functions

emit(sink, tenant_id, event)
replay(sink, tenant_id, execution_id, opts \\ [])

Types

event()

@type event() :: WorkflowStem.Adapters.EventSink.event()

Functions

emit(sink, tenant_id, event)

@spec emit(module() | nil, String.t(), event()) :: {:ok, event()} | {:error, term()}

replay(sink, tenant_id, execution_id, opts \\ [])

@spec replay(module() | nil, String.t(), String.t(), keyword()) ::
  {:ok, [event()]} | {:error, term()}