Chronicle.Group (chronicle v0.1.0)

The durable envelope for a larger audited unit of work.

A group has its own identity and outcome and contains zero or more ordered Chronicle.Events. Events in a group may come from unrelated mechanisms—for example an Ecto update, an authorization decision, and a message publish.

A group is stored as a record row alongside its events rather than in a separate table: it shares their identity, actor, subject, and correlation columns, and adds only the child count. One signed ledger entry covers the group and all of its children.

Summary

Types

t()

Functions

complete(group, outcome, duration_us, event_count, error \\ nil)

ended_at(started_at, duration_us)

Derives the end of a unit from its start and monotonic duration.

new(type, opts \\ [])

Types

t()

@type t() :: %Chronicle.Group{
  actor: map() | nil,
  correlation_id: String.t() | nil,
  data: map(),
  duration_us: non_neg_integer() | nil,
  ended_at: DateTime.t() | nil,
  error: map() | nil,
  event_count: non_neg_integer() | nil,
  id: String.t(),
  metadata: map(),
  outcome: Chronicle.Event.outcome(),
  started_at: DateTime.t(),
  subject: map() | nil,
  tenant: map() | nil,
  type: String.t()
}

Functions

complete(group, outcome, duration_us, event_count, error \\ nil)

@spec complete(
  t(),
  Chronicle.Event.outcome(),
  non_neg_integer(),
  non_neg_integer(),
  map() | nil
) :: t()

ended_at(started_at, duration_us)

@spec ended_at(DateTime.t(), non_neg_integer() | nil) :: DateTime.t() | nil

Derives the end of a unit from its start and monotonic duration.

duration_us is measured monotonically, so deriving the end from it is consistent by construction. A second wall-clock reading could disagree with it, or move backwards across a clock adjustment.

new(type, opts \\ [])

@spec new(
  String.t(),
  keyword()
) :: t()