Outbox.ConsumedEvent (Outbox v0.1.0-beta.2)

Ecto schema for the outbox_consumed_events table — the idempotency ledger written by Outbox.Idempotency.run_once/3.

Each row records that a given consumer has processed a given event_id exactly once. The composite primary key (consumer, event_id) is what makes a duplicate delivery a no-op.

Summary

Types

t()

Types

t()

@type t() :: %Outbox.ConsumedEvent{
  __meta__: term(),
  consumer: String.t() | nil,
  event_id: String.t() | nil,
  inserted_at: DateTime.t() | nil
}