StatifierRouter.Schema.Subscription (StatifierRouter v0.9.2)

Copy Markdown View Source

A row of the subscription table: one live source invocation, as (execution_id, binding_id, invoke_id), carrying the scope and key the subscription reads events under (ADR-0007, section 6). Both are resolved once, at subscribe time, from the execution's own address row.

The unique index on (execution_id, binding_id, invoke_id) is named in StatifierRouter.Migrations.V02; see StatifierRouter.Schema for how a row reaches a configured table.

Summary

Types

t()

@type t() :: %StatifierRouter.Schema.Subscription{
  __meta__: term(),
  binding_id: String.t() | nil,
  execution_id: String.t() | nil,
  id: StatifierRouter.Schema.Id.t() | nil,
  inserted_at: DateTime.t() | nil,
  invoke_id: String.t() | nil,
  key: String.t() | nil,
  scope: String.t() | nil
}