Midaz events

Midaz emits its public JSON business facts as CloudEvents 1.0 in binary content mode over Kafka through lib-streaming.

Public JSON ledger catalog

The public ledger manifest contains the following verified definitions. Every cataloged definition has a non-test production emission path.

Cataloged	Emitted	Catalog-only
49	49	0

CloudEvents envelope

Every public JSON fact uses the shared envelope below. The headers carry routing and schema information; the Kafka value carries the JSON data object.

Header	Presence and value
`ce-specversion`	Always `1.0`.
`ce-id`	Always; opaque producer-defined event identifier.
`ce-source`	Always `ledger`.
`ce-type`	Always `studio.lerian.ledger.<resource>.<event>`.
`ce-time`	Always; RFC 3339 emission timestamp.
`ce-resourcetype`	Always; the resource token from the definition key.
`ce-eventtype`	Always; the event token from the definition key.
`ce-subject`	Set by the payload-specific expression listed with each contract.
`ce-tenantid`	Always present. The resolved tenant ID in multi-tenant scope; literal `default` in single-tenant or tenantless scope.
`ce-schemaversion`	Always `1.0.0` for the 49 public JSON facts.
`ce-datacontenttype`	`application/json`.

Topics, manifest, and routing

The application topic identifies the producing application, not an individual event. Route a record by ce-resourcetype and ce-eventtype, and validate ce-schemaversion before decoding its data value.

Facts: lerian.streaming.ledger
Route DLQ: lerian.streaming.ledger.dlq
Manifest: GET /v1/streaming/manifest exposes the public JSON catalog and topic mapping, including while publication is disabled.

Delivery and failure semantics

Publication is disabled until STREAMING_ENABLED=true and broker configuration succeeds. When enabled, Midaz emits after the business-state change. It does not wire a lib-streaming outbox writer, outbox repository, transactional outbox, or outbox relay.

Policy: every public JSON definition is a fact with direct delivery, on_routable_failure DLQ handling, and fallback_on_circuit_open configured by lib-streaming v3.
Actual Midaz boundary: because no outbox writer is wired, the circuit-open fallback cannot persist an event. Emit paths log and swallow publication errors instead of returning them to the business command.
Consumer requirement: broker delivery is at least once for published records. Make handlers idempotent and deduplicate with (ce-source, ce-id).

Separate legacy RabbitMQ plane

Midaz also has compatibility exchanges for selected transaction, overdraft, and audit notifications. They are a separate legacy RabbitMQ plane, not a lib-streaming contract and not a complete representation of this 49-event public JSON catalog. New integrations should use the Kafka contract on this page.

Complete `data` contracts

These TypeScript-style declarations mirror the producer wire shape. Every field name is its JSON name. ? means the field has omitempty; | null means the field is nullable without omitting it. A source-type comment preserves the inventory type exactly. Decimal values are JSON strings, never binary floating-point numbers.

Shared source-type mappings

type DecimalString = string // JSON encoding of decimal.Decimal
type JsonRawMessage = unknown // Go: json.RawMessage

type MmodelStatus = { // Go: mmodel.Status
  code: string // string; wire null: false; omitempty: false
  description: string | null // *string; wire null: true; omitempty: false
}

type BalanceSettings = { // Go: mmodel.BalanceSettings
  balanceScope?: string // string; wire null: false; omitempty: true
  allowOverdraft: boolean // bool; wire null: false; omitempty: false
  overdraftLimitEnabled: boolean // bool; wire null: false; omitempty: false
  overdraftLimit?: string // *string; wire null: false; omitempty: true
}

type AccountingRubric = { // Go: mmodel.AccountingRubric
  code: string // string; wire null: false; omitempty: false
  description: string // string; wire null: false; omitempty: false
}

type AccountingEntry = { // Go: mmodel.AccountingEntry
  debit: AccountingRubric | null // *AccountingRubric; wire null: true; omitempty: false
  credit: AccountingRubric | null // *AccountingRubric; wire null: true; omitempty: false
}

type AccountingEntries = { // Go: mmodel.AccountingEntries
  direct?: AccountingEntry // *AccountingEntry; wire null: false; omitempty: true
  hold?: AccountingEntry // *AccountingEntry; wire null: false; omitempty: true
  commit?: AccountingEntry // *AccountingEntry; wire null: false; omitempty: true
  cancel?: AccountingEntry // *AccountingEntry; wire null: false; omitempty: true
  revert?: AccountingEntry // *AccountingEntry; wire null: false; omitempty: true
  overdraft?: AccountingEntry // *AccountingEntry; wire null: false; omitempty: true
  block?: AccountingEntry // *AccountingEntry; wire null: false; omitempty: true
  unblock?: AccountingEntry // *AccountingEntry; wire null: false; omitempty: true
}

type AccountRule = { // Go: mmodel.AccountRule
  ruleType?: string // string; wire null: false; omitempty: true
  validIf?: unknown // any; wire null: false; omitempty: true
}

account.created

Event: studio.lerian.ledger.account.createdTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An account is opened in a ledger.Subject: account ID (p.ID)

type AccountStatusPayload = {
  code: string // string; wire null: false; omitempty: false
  description?: string // *string; wire null: false; omitempty: true
}

// account.created
type AccountCreatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  name: string // string; wire null: false; omitempty: false
  assetCode: string // string; wire null: false; omitempty: false
  type: string // string; wire null: false; omitempty: false
  portfolioId: string | null // *string; wire null: true; omitempty: false
  segmentId: string | null // *string; wire null: true; omitempty: false
  parentAccountId: string | null // *string; wire null: true; omitempty: false
  entityId: string | null // *string; wire null: true; omitempty: false
  holderId: string | null // *string; wire null: true; omitempty: false
  alias: string | null // *string; wire null: true; omitempty: false
  status: AccountStatusPayload // AccountStatusPayload; wire null: false; omitempty: false
  blocked: boolean | null // *bool; wire null: true; omitempty: false
  holderCheckSkipped: boolean // bool; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

account.deleted

Event: studio.lerian.ledger.account.deletedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An account is deleted.Subject: account ID (p.ID)

// account.deleted
type AccountDeletedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  portfolioId: string | null // *string; wire null: true; omitempty: false
  deletedAt: string // string; wire null: false; omitempty: false
}

account.updated

Event: studio.lerian.ledger.account.updatedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An account’s mutable fields change.Subject: account ID (p.ID)

type AccountStatusPayload = {
  code: string // string; wire null: false; omitempty: false
  description?: string // *string; wire null: false; omitempty: true
}

// account.updated
type AccountUpdatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  name: string // string; wire null: false; omitempty: false
  portfolioId: string | null // *string; wire null: true; omitempty: false
  segmentId: string | null // *string; wire null: true; omitempty: false
  entityId: string | null // *string; wire null: true; omitempty: false
  status: AccountStatusPayload // AccountStatusPayload; wire null: false; omitempty: false
  blocked: boolean | null // *bool; wire null: true; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

asset.created

Event: studio.lerian.ledger.asset.createdTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An asset is registered in a ledger.Subject: asset ID (p.ID)

type AssetStatusPayload = {
  code: string // string; wire null: false; omitempty: false
  description?: string // *string; wire null: false; omitempty: true
}

// asset.created
type AssetCreatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  name: string // string; wire null: false; omitempty: false
  type: string // string; wire null: false; omitempty: false
  code: string // string; wire null: false; omitempty: false
  status: AssetStatusPayload // AssetStatusPayload; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

asset.deleted

Event: studio.lerian.ledger.asset.deletedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An asset is deleted.Subject: asset ID (p.ID)

// asset.deleted
type AssetDeletedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  deletedAt: string // string; wire null: false; omitempty: false
}

asset.updated

Event: studio.lerian.ledger.asset.updatedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An asset’s mutable fields change.Subject: asset ID (p.ID)

type AssetStatusPayload = {
  code: string // string; wire null: false; omitempty: false
  description?: string // *string; wire null: false; omitempty: true
}

// asset.updated
type AssetUpdatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  name: string // string; wire null: false; omitempty: false
  type: string // string; wire null: false; omitempty: false
  code: string // string; wire null: false; omitempty: false
  status: AssetStatusPayload // AssetStatusPayload; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

balance.changed

Event: studio.lerian.ledger.balance.changedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A committed transaction moves a balance — one event per balance-affecting operation; values reflect the state after the operation.Subject: transaction ID and operation ID (p.TransactionID + ":" + p.OperationID)

// balance.changed
type BalanceChangedDataV1 = {
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  accountId: string // string; wire null: false; omitempty: false
  balanceId: string // string; wire null: false; omitempty: false
  alias?: string // string; wire null: false; omitempty: true
  assetCode: string // string; wire null: false; omitempty: false
  balanceKey: string // string; wire null: false; omitempty: false
  available: DecimalString // decimal.Decimal; wire null: false; omitempty: false
  onHold: DecimalString // decimal.Decimal; wire null: false; omitempty: false
  version: number // int64; wire null: false; omitempty: false
  reason: string // string; wire null: false; omitempty: false
  operationType: string // string; wire null: false; omitempty: false
  direction?: string // string; wire null: false; omitempty: true
  amount: DecimalString // decimal.Decimal; wire null: false; omitempty: false
  transactionId: string // string; wire null: false; omitempty: false
  operationId: string // string; wire null: false; omitempty: false
  occurredAt: string // string; wire null: false; omitempty: false
}

balance.config_changed

Event: studio.lerian.ledger.balance.config_changedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A balance’s settings change, or overdraft is enabled (companion balance materialized). changeType discriminates settings_updated from overdraft_enabled.Subject: balance ID (p.ID)

// balance.config_changed
type BalanceConfigChangedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  accountId: string // string; wire null: false; omitempty: false
  alias?: string // string; wire null: false; omitempty: true
  key: string // string; wire null: false; omitempty: false
  allowSending: boolean // bool; wire null: false; omitempty: false
  allowReceiving: boolean // bool; wire null: false; omitempty: false
  direction?: string // string; wire null: false; omitempty: true
  settings?: BalanceSettings // *mmodel.BalanceSettings; wire null: false; omitempty: true
  changeType: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

balance.created

Event: studio.lerian.ledger.balance.createdTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A balance is created during account setup.Subject: balance ID (p.ID)

// balance.created
type BalanceCreatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  accountId: string // string; wire null: false; omitempty: false
  alias?: string // string; wire null: false; omitempty: true
  key: string // string; wire null: false; omitempty: false
  assetCode: string // string; wire null: false; omitempty: false
  accountType?: string // string; wire null: false; omitempty: true
  available: DecimalString // decimal.Decimal; wire null: false; omitempty: false
  onHold: DecimalString // decimal.Decimal; wire null: false; omitempty: false
  allowSending: boolean // bool; wire null: false; omitempty: false
  allowReceiving: boolean // bool; wire null: false; omitempty: false
  direction?: string // string; wire null: false; omitempty: true
  settings?: BalanceSettings // *mmodel.BalanceSettings; wire null: false; omitempty: true
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

balance.deleted

Event: studio.lerian.ledger.balance.deletedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A balance is deleted.Subject: balance ID (p.ID)

// balance.deleted
type BalanceDeletedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  accountId: string // string; wire null: false; omitempty: false
  deletedAt: string // string; wire null: false; omitempty: false
}

balance.overdraft_cleared

Event: studio.lerian.ledger.balance.overdraft_clearedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: Overdraft is fully repaid — terminal signal (action = cleared).Subject: transaction ID and operation ID (p.TransactionID + ":" + p.OperationID)

// balance.overdraft_cleared
type BalanceOverdraftClearedDataV1 = {
  balanceId: string // string; wire null: false; omitempty: false
  accountId: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  assetCode: string // string; wire null: false; omitempty: false
  transactionId: string // string; wire null: false; omitempty: false
  operationId: string // string; wire null: false; omitempty: false
  action: string // string; wire null: false; omitempty: false
  amount: DecimalString // decimal.Decimal; wire null: false; omitempty: false
  overdraftBalance: DecimalString // decimal.Decimal; wire null: false; omitempty: false
  overdraftLimit?: DecimalString // *decimal.Decimal; wire null: false; omitempty: true
  occurredAt: string // string; wire null: false; omitempty: false
}

balance.overdraft_drawn

Event: studio.lerian.ledger.balance.overdraft_drawnTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A debit consumes overdraft beyond available funds (action = drawn).Subject: transaction ID and operation ID (p.TransactionID + ":" + p.OperationID)

// balance.overdraft_drawn
type BalanceOverdraftDrawnDataV1 = {
  balanceId: string // string; wire null: false; omitempty: false
  accountId: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  assetCode: string // string; wire null: false; omitempty: false
  transactionId: string // string; wire null: false; omitempty: false
  operationId: string // string; wire null: false; omitempty: false
  action: string // string; wire null: false; omitempty: false
  amount: DecimalString // decimal.Decimal; wire null: false; omitempty: false
  overdraftBalance: DecimalString // decimal.Decimal; wire null: false; omitempty: false
  overdraftLimit?: DecimalString // *decimal.Decimal; wire null: false; omitempty: true
  occurredAt: string // string; wire null: false; omitempty: false
}

balance.overdraft_repaid

Event: studio.lerian.ledger.balance.overdraft_repaidTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: Overdraft usage decreases but is not fully cleared (action = repaid).Subject: transaction ID and operation ID (p.TransactionID + ":" + p.OperationID)

// balance.overdraft_repaid
type BalanceOverdraftRepaidDataV1 = {
  balanceId: string // string; wire null: false; omitempty: false
  accountId: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  assetCode: string // string; wire null: false; omitempty: false
  transactionId: string // string; wire null: false; omitempty: false
  operationId: string // string; wire null: false; omitempty: false
  action: string // string; wire null: false; omitempty: false
  amount: DecimalString // decimal.Decimal; wire null: false; omitempty: false
  overdraftBalance: DecimalString // decimal.Decimal; wire null: false; omitempty: false
  overdraftLimit?: DecimalString // *decimal.Decimal; wire null: false; omitempty: true
  occurredAt: string // string; wire null: false; omitempty: false
}

fee_billing_packages.created

Event: studio.lerian.ledger.fee_billing_packages.createdTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A billing package is created.Subject: billing package ID (p.ID)

// fee_billing_packages.created
type FeeBillingPackagesCreatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  type: string // string; wire null: false; omitempty: false
  pricingModel: string | null // *string; wire null: true; omitempty: false
  countMode: string | null // *string; wire null: true; omitempty: false
  enable: boolean // bool; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

fee_billing_packages.deleted

Event: studio.lerian.ledger.fee_billing_packages.deletedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A billing package is deleted.Subject: billing package ID (p.ID)

// fee_billing_packages.deleted
type FeeBillingPackagesDeletedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  deletedAt: string // string; wire null: false; omitempty: false
}

fee_billing_packages.updated

Event: studio.lerian.ledger.fee_billing_packages.updatedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A billing package’s mutable fields change.Subject: billing package ID (p.ID)

// fee_billing_packages.updated
type FeeBillingPackagesUpdatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  type: string // string; wire null: false; omitempty: false
  pricingModel: string | null // *string; wire null: true; omitempty: false
  countMode: string | null // *string; wire null: true; omitempty: false
  enable: boolean // bool; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

fee_charge.applied

Event: studio.lerian.ledger.fee_charge.appliedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A fee package is applied to a committed transaction.Subject: transaction ID (p.TransactionID)

// fee_charge.applied
type FeeChargeAppliedDataV1 = {
  transactionId: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  feePackageId: string // string; wire null: false; omitempty: false
  appliedAt: string // string; wire null: false; omitempty: false
}

fee_packages.created

Event: studio.lerian.ledger.fee_packages.createdTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A fee package is created.Subject: fee package ID (p.ID)

// fee_packages.created
type FeePackagesCreatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  segmentId: string | null // *string; wire null: true; omitempty: false
  transactionRoute: string | null // *string; wire null: true; omitempty: false
  enable: boolean // bool; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

fee_packages.deleted

Event: studio.lerian.ledger.fee_packages.deletedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A fee package is deleted.Subject: fee package ID (p.ID)

// fee_packages.deleted
type FeePackagesDeletedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  deletedAt: string // string; wire null: false; omitempty: false
}

fee_packages.updated

Event: studio.lerian.ledger.fee_packages.updatedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A fee package’s mutable fields change.Subject: fee package ID (p.ID)

// fee_packages.updated
type FeePackagesUpdatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  segmentId: string | null // *string; wire null: true; omitempty: false
  transactionRoute: string | null // *string; wire null: true; omitempty: false
  enable: boolean // bool; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

holder.created

Event: studio.lerian.ledger.holder.createdTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A holder is created.Subject: holder ID (p.ID)

// holder.created
type HolderCreatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  type: string // string; wire null: false; omitempty: false
  externalId: string | null // *string; wire null: true; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

holder.deleted

Event: studio.lerian.ledger.holder.deletedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A holder is deleted.Subject: holder ID (p.ID)

// holder.deleted
type HolderDeletedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  deletionType: string // string; wire null: false; omitempty: false
  deletedAt: string // string; wire null: false; omitempty: false
}

holder.updated

Event: studio.lerian.ledger.holder.updatedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A holder’s mutable fields change.Subject: holder ID (p.ID)

// holder.updated
type HolderUpdatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  type: string // string; wire null: false; omitempty: false
  externalId: string | null // *string; wire null: true; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

instrument.created

Event: studio.lerian.ledger.instrument.createdTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An instrument is created for a holder and account.Subject: instrument ID (p.ID)

type InstrumentRelatedPartyPayload = {
  relatedPartyId: string // string; wire null: false; omitempty: false
  role: string // string; wire null: false; omitempty: false
}

// instrument.created
type InstrumentCreatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  holderId: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  accountId: string // string; wire null: false; omitempty: false
  type: string // string; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
  relatedParties: InstrumentRelatedPartyPayload[] // []InstrumentRelatedPartyPayload; wire null: false; omitempty: false
}

instrument.deleted

Event: studio.lerian.ledger.instrument.deletedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An instrument is deleted.Subject: instrument ID (p.ID)

// instrument.deleted
type InstrumentDeletedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  holderId: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  deletionType: string // string; wire null: false; omitempty: false
  deletedAt: string // string; wire null: false; omitempty: false
}

Event: studio.lerian.ledger.instrument.related_party_deletedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A single related party is removed from an instrument (ce-subject is the instrument id).Subject: instrument ID (p.InstrumentID)

// instrument.related_party_deleted
type InstrumentRelatedPartyDeletedDataV1 = {
  instrumentId: string // string; wire null: false; omitempty: false
  holderId: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  relatedPartyId: string // string; wire null: false; omitempty: false
  deletedAt: string // string; wire null: false; omitempty: false
}

instrument.updated

Event: studio.lerian.ledger.instrument.updatedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An instrument’s mutable fields change.Subject: instrument ID (p.ID)

type InstrumentRelatedPartyPayload = {
  relatedPartyId: string // string; wire null: false; omitempty: false
  role: string // string; wire null: false; omitempty: false
}

// instrument.updated
type InstrumentUpdatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  holderId: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  accountId: string // string; wire null: false; omitempty: false
  type: string // string; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
  relatedParties: InstrumentRelatedPartyPayload[] // []InstrumentRelatedPartyPayload; wire null: false; omitempty: false
}

ledger.created

Event: studio.lerian.ledger.ledger.createdTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A ledger is created within an organization.Subject: ledger ID (p.ID)

type LedgerStatusPayload = {
  code: string // string; wire null: false; omitempty: false
  description?: string // *string; wire null: false; omitempty: true
}

// ledger.created
type LedgerCreatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  name: string // string; wire null: false; omitempty: false
  status: LedgerStatusPayload // LedgerStatusPayload; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

ledger.deleted

Event: studio.lerian.ledger.ledger.deletedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A ledger is deleted.Subject: ledger ID (p.ID)

// ledger.deleted
type LedgerDeletedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  deletedAt: string // string; wire null: false; omitempty: false
}

ledger.updated

Event: studio.lerian.ledger.ledger.updatedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A ledger’s name or status changes.Subject: ledger ID (p.ID)

type LedgerStatusPayload = {
  code: string // string; wire null: false; omitempty: false
  description?: string // *string; wire null: false; omitempty: true
}

// ledger.updated
type LedgerUpdatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  name: string // string; wire null: false; omitempty: false
  status: LedgerStatusPayload // LedgerStatusPayload; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

operation_route.created

Event: studio.lerian.ledger.operation_route.createdTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An operation route is created.Subject: operation-route ID (p.ID)

// operation_route.created
type OperationRouteCreatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  title: string // string; wire null: false; omitempty: false
  description?: string // string; wire null: false; omitempty: true
  code?: string // string; wire null: false; omitempty: true
  operationType: string // string; wire null: false; omitempty: false
  account?: AccountRule // *mmodel.AccountRule; wire null: false; omitempty: true
  accountingEntries?: AccountingEntries // *mmodel.AccountingEntries; wire null: false; omitempty: true
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

operation_route.deleted

Event: studio.lerian.ledger.operation_route.deletedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An operation route is deleted.Subject: operation-route ID (p.ID)

// operation_route.deleted
type OperationRouteDeletedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  deletedAt: string // string; wire null: false; omitempty: false
}

operation_route.updated

Event: studio.lerian.ledger.operation_route.updatedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An operation route’s mutable fields change.Subject: operation-route ID (p.ID)

// operation_route.updated
type OperationRouteUpdatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  title: string // string; wire null: false; omitempty: false
  description?: string // string; wire null: false; omitempty: true
  code?: string // string; wire null: false; omitempty: true
  operationType: string // string; wire null: false; omitempty: false
  account?: AccountRule // *mmodel.AccountRule; wire null: false; omitempty: true
  accountingEntries?: AccountingEntries // *mmodel.AccountingEntries; wire null: false; omitempty: true
  updatedAt: string // string; wire null: false; omitempty: false
}

organization.created

Event: studio.lerian.ledger.organization.createdTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An organization is created.Subject: organization ID (p.ID)

type OrganizationAddressPayload = {
  line1: string // string; wire null: false; omitempty: false
  line2: string | null // *string; wire null: true; omitempty: false
  zipCode: string // string; wire null: false; omitempty: false
  city: string // string; wire null: false; omitempty: false
  state: string // string; wire null: false; omitempty: false
  country: string // string; wire null: false; omitempty: false
  description?: string // *string; wire null: false; omitempty: true
}

type OrganizationStatusPayload = {
  code: string // string; wire null: false; omitempty: false
  description?: string // *string; wire null: false; omitempty: true
}

// organization.created
type OrganizationCreatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  parentOrganizationId: string | null // *string; wire null: true; omitempty: false
  legalName: string // string; wire null: false; omitempty: false
  doingBusinessAs: string | null // *string; wire null: true; omitempty: false
  legalDocument: string // string; wire null: false; omitempty: false
  address: OrganizationAddressPayload // OrganizationAddressPayload; wire null: false; omitempty: false
  status: OrganizationStatusPayload // OrganizationStatusPayload; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

organization.deleted

Event: studio.lerian.ledger.organization.deletedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An organization is deleted.Subject: organization ID (p.ID)

// organization.deleted
type OrganizationDeletedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  deletedAt: string // string; wire null: false; omitempty: false
}

organization.updated

Event: studio.lerian.ledger.organization.updatedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: An organization’s mutable fields change.Subject: organization ID (p.ID)

type OrganizationAddressPayload = {
  line1: string // string; wire null: false; omitempty: false
  line2: string | null // *string; wire null: true; omitempty: false
  zipCode: string // string; wire null: false; omitempty: false
  city: string // string; wire null: false; omitempty: false
  state: string // string; wire null: false; omitempty: false
  country: string // string; wire null: false; omitempty: false
  description?: string // *string; wire null: false; omitempty: true
}

type OrganizationStatusPayload = {
  code: string // string; wire null: false; omitempty: false
  description?: string // *string; wire null: false; omitempty: true
}

// organization.updated
type OrganizationUpdatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  parentOrganizationId: string | null // *string; wire null: true; omitempty: false
  legalName: string // string; wire null: false; omitempty: false
  doingBusinessAs: string | null // *string; wire null: true; omitempty: false
  address: OrganizationAddressPayload // OrganizationAddressPayload; wire null: false; omitempty: false
  status: OrganizationStatusPayload // OrganizationStatusPayload; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

portfolio.created

Event: studio.lerian.ledger.portfolio.createdTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A portfolio is created.Subject: portfolio ID (p.ID)

type PortfolioStatusPayload = {
  code: string // string; wire null: false; omitempty: false
  description?: string // *string; wire null: false; omitempty: true
}

// portfolio.created
type PortfolioCreatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  name: string // string; wire null: false; omitempty: false
  entityId?: string // string; wire null: false; omitempty: true
  status: PortfolioStatusPayload // PortfolioStatusPayload; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

portfolio.deleted

Event: studio.lerian.ledger.portfolio.deletedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A portfolio is deleted.Subject: portfolio ID (p.ID)

// portfolio.deleted
type PortfolioDeletedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  deletedAt: string // string; wire null: false; omitempty: false
}

portfolio.updated

Event: studio.lerian.ledger.portfolio.updatedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A portfolio’s mutable fields change.Subject: portfolio ID (p.ID)

type PortfolioStatusPayload = {
  code: string // string; wire null: false; omitempty: false
  description?: string // *string; wire null: false; omitempty: true
}

// portfolio.updated
type PortfolioUpdatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  name: string // string; wire null: false; omitempty: false
  entityId?: string // string; wire null: false; omitempty: true
  status: PortfolioStatusPayload // PortfolioStatusPayload; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

segment.created

Event: studio.lerian.ledger.segment.createdTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A segment is created.Subject: segment ID (p.ID)

type SegmentStatusPayload = {
  code: string // string; wire null: false; omitempty: false
  description?: string // *string; wire null: false; omitempty: true
}

// segment.created
type SegmentCreatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  name: string // string; wire null: false; omitempty: false
  status: SegmentStatusPayload // SegmentStatusPayload; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

segment.deleted

Event: studio.lerian.ledger.segment.deletedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A segment is deleted.Subject: segment ID (p.ID)

// segment.deleted
type SegmentDeletedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  deletedAt: string // string; wire null: false; omitempty: false
}

segment.updated

Event: studio.lerian.ledger.segment.updatedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A segment’s mutable fields change.Subject: segment ID (p.ID)

type SegmentStatusPayload = {
  code: string // string; wire null: false; omitempty: false
  description?: string // *string; wire null: false; omitempty: true
}

// segment.updated
type SegmentUpdatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  name: string // string; wire null: false; omitempty: false
  status: SegmentStatusPayload // SegmentStatusPayload; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

transaction.canceled

Event: studio.lerian.ledger.transaction.canceledTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A pending transaction transitions from PENDING to CANCELED.Subject: transaction ID (p.ID)

// transaction.canceled
type TransactionCanceledDataV1 = {
  id: string // string; wire null: false; omitempty: false
  parentTransactionId?: string // *string; wire null: false; omitempty: true
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  status: MmodelStatus // mmodel.Status; wire null: false; omitempty: false
  amount?: DecimalString // *decimal.Decimal; wire null: false; omitempty: true
  assetCode: string // string; wire null: false; omitempty: false
  chartOfAccountsGroupName?: string // string; wire null: false; omitempty: true
  description?: string // string; wire null: false; omitempty: true
  source?: string[] // []string; wire null: false; omitempty: true
  destination?: string[] // []string; wire null: false; omitempty: true
  route?: string // string; wire null: false; omitempty: true
  routeId?: string // *string; wire null: false; omitempty: true
  operations: JsonRawMessage[] // []json.RawMessage; wire null: false; omitempty: false
  metadata?: Record<string, unknown> // map[string]any; wire null: false; omitempty: true
  feesSkipped: boolean // bool; wire null: false; omitempty: false
  tracerSkipped: boolean // bool; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

transaction.committed

Event: studio.lerian.ledger.transaction.committedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A pending transaction transitions from PENDING to APPROVED.Subject: transaction ID (p.ID)

// transaction.committed
type TransactionCommittedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  parentTransactionId?: string // *string; wire null: false; omitempty: true
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  status: MmodelStatus // mmodel.Status; wire null: false; omitempty: false
  amount?: DecimalString // *decimal.Decimal; wire null: false; omitempty: true
  assetCode: string // string; wire null: false; omitempty: false
  chartOfAccountsGroupName?: string // string; wire null: false; omitempty: true
  description?: string // string; wire null: false; omitempty: true
  source?: string[] // []string; wire null: false; omitempty: true
  destination?: string[] // []string; wire null: false; omitempty: true
  route?: string // string; wire null: false; omitempty: true
  routeId?: string // *string; wire null: false; omitempty: true
  operations: JsonRawMessage[] // []json.RawMessage; wire null: false; omitempty: false
  metadata?: Record<string, unknown> // map[string]any; wire null: false; omitempty: true
  feesSkipped: boolean // bool; wire null: false; omitempty: false
  tracerSkipped: boolean // bool; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

transaction.posted

Event: studio.lerian.ledger.transaction.postedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A newly created transaction is committed to storage with all its operations persisted (no parent).Subject: transaction ID (p.ID)

// transaction.posted
type TransactionPostedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  parentTransactionId?: string // *string; wire null: false; omitempty: true
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  status: MmodelStatus // mmodel.Status; wire null: false; omitempty: false
  amount?: DecimalString // *decimal.Decimal; wire null: false; omitempty: true
  assetCode: string // string; wire null: false; omitempty: false
  chartOfAccountsGroupName?: string // string; wire null: false; omitempty: true
  description?: string // string; wire null: false; omitempty: true
  source?: string[] // []string; wire null: false; omitempty: true
  destination?: string[] // []string; wire null: false; omitempty: true
  route?: string // string; wire null: false; omitempty: true
  routeId?: string // *string; wire null: false; omitempty: true
  operations: JsonRawMessage[] // []json.RawMessage; wire null: false; omitempty: false
  metadata?: Record<string, unknown> // map[string]any; wire null: false; omitempty: true
  feesSkipped: boolean // bool; wire null: false; omitempty: false
  tracerSkipped: boolean // bool; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

transaction.reverted

Event: studio.lerian.ledger.transaction.revertedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A revert flow creates a child transaction; parentTransactionId correlates it to the original.Subject: transaction ID (p.ID)

// transaction.reverted
type TransactionRevertedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  parentTransactionId?: string // *string; wire null: false; omitempty: true
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  status: MmodelStatus // mmodel.Status; wire null: false; omitempty: false
  amount?: DecimalString // *decimal.Decimal; wire null: false; omitempty: true
  assetCode: string // string; wire null: false; omitempty: false
  chartOfAccountsGroupName?: string // string; wire null: false; omitempty: true
  description?: string // string; wire null: false; omitempty: true
  source?: string[] // []string; wire null: false; omitempty: true
  destination?: string[] // []string; wire null: false; omitempty: true
  route?: string // string; wire null: false; omitempty: true
  routeId?: string // *string; wire null: false; omitempty: true
  operations: JsonRawMessage[] // []json.RawMessage; wire null: false; omitempty: false
  metadata?: Record<string, unknown> // map[string]any; wire null: false; omitempty: true
  feesSkipped: boolean // bool; wire null: false; omitempty: false
  tracerSkipped: boolean // bool; wire null: false; omitempty: false
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

transaction_route.created

Event: studio.lerian.ledger.transaction_route.createdTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A transaction route is created.Subject: transaction-route ID (p.ID)

// transaction_route.created
type TransactionRouteCreatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  title: string // string; wire null: false; omitempty: false
  description?: string // string; wire null: false; omitempty: true
  operationRouteIds?: string[] // []string; wire null: false; omitempty: true
  createdAt: string // string; wire null: false; omitempty: false
  updatedAt: string // string; wire null: false; omitempty: false
}

transaction_route.deleted

Event: studio.lerian.ledger.transaction_route.deletedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A transaction route is deleted.Subject: transaction-route ID (p.ID)

// transaction_route.deleted
type TransactionRouteDeletedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  deletedAt: string // string; wire null: false; omitempty: false
}

transaction_route.updated

Event: studio.lerian.ledger.transaction_route.updatedTopic: lerian.streaming.ledgerRoute DLQ: lerian.streaming.ledger.dlqSchema: 1.0.0Fires when: A transaction route’s mutable fields change.Subject: transaction-route ID (p.ID)

// transaction_route.updated
type TransactionRouteUpdatedDataV1 = {
  id: string // string; wire null: false; omitempty: false
  organizationId: string // string; wire null: false; omitempty: false
  ledgerId: string // string; wire null: false; omitempty: false
  title: string // string; wire null: false; omitempty: false
  description?: string // string; wire null: false; omitempty: true
  operationRouteIds?: string[] // []string; wire null: false; omitempty: true
  updatedAt: string // string; wire null: false; omitempty: false
}

Internal billing event (outside the public catalog)

billing_recorded is emitted separately from the 49 public JSON facts. It uses Confluent-framed Protobuf, not the public JSON manifest, and its fixed topic is lerian.streaming.billing.recorded. Do not count it as a manifest event or decode it as the JSON data contracts above. It keeps the CloudEvents 1.0 headers with ce-source=ledger, ce-resourcetype=billing, ce-eventtype=recorded, and ce-time set to the transaction creation time. CloudEvents type: studio.lerian.ledger.billing.recorded Topic: lerian.streaming.billing.recorded Content type: application/vnd.confluent.protobuf Schema: 1.0.0 Route DLQ: lerian.streaming.ledger.dlq Tenant: ce-tenantid follows the same resolved-tenant or literal default rule as the public facts. Subject: account ID Fires when: A non-noop transaction lifecycle write leaves the transaction in APPROVED status; Midaz emits one record for each unique non-external account referenced by its operations.

// billing_recorded
type ProtobufTimestamp = {
  seconds: bigint // protobuf int64
  nanos: number // protobuf int32
}

type BillingPropertyValue =
  | { string_value: string; number_value?: never }
  | { string_value?: never; number_value: number } // validated oneof

type BillingRecordedData = {
  metric: string // required protobuf string
  subscription_id: string // required protobuf string
  timestamp?: ProtobufTimestamp // optional; absent when unset
  properties?: Record<string, BillingPropertyValue> // protobuf map; absent when empty
  precise_total_amount_cents?: string // optional protobuf string; absent when unset
}

Midaz populates metric as active_account; properties.account_id and properties.transaction_id as strings; and subscription_id as the tenant ID in multi-tenant mode or the transaction organization ID otherwise.

Overview

Midaz

Tracer

Lender

Matcher

Reporter

Fetcher

Consignado

Public JSON ledger catalog

CloudEvents envelope

Topics, manifest, and routing

Delivery and failure semantics

Separate legacy RabbitMQ plane

Complete `data` contracts

Shared source-type mappings

Internal billing event (outside the public catalog)

​Public JSON ledger catalog

​CloudEvents envelope

​Topics, manifest, and routing

​Delivery and failure semantics

​Separate legacy RabbitMQ plane

​Complete data contracts

​Shared source-type mappings

​Internal billing event (outside the public catalog)

Public JSON ledger catalog

CloudEvents envelope

Topics, manifest, and routing

Delivery and failure semantics

Separate legacy RabbitMQ plane

Complete `data` contracts

Shared source-type mappings

Internal billing event (outside the public catalog)