Eventos do Midaz

O Midaz emite seus fatos públicos de negócio JSON como CloudEvents 1.0 em modo de conteúdo binário sobre Kafka por meio da lib-streaming.

Catálogo público JSON do ledger

O manifesto público do ledger contém as definições verificadas abaixo. Toda definição catalogada possui um caminho de emissão de produção não relacionado a testes.

Catalogados	Emitidos	Apenas catalogados
49	49	0

Envelope CloudEvents

Todo fato JSON público usa o envelope compartilhado abaixo. Os cabeçalhos carregam informações de roteamento e esquema; o valor Kafka carrega o objeto JSON data.

Cabeçalho	Presença e valor
`ce-specversion`	Sempre `1.0`.
`ce-id`	Sempre; identificador opaco do evento definido pelo produtor.
`ce-source`	Sempre `ledger`.
`ce-type`	Sempre `studio.lerian.ledger.<resource>.<event>`.
`ce-time`	Sempre; carimbo de emissão RFC 3339.
`ce-resourcetype`	Sempre; o token de recurso da chave de definição.
`ce-eventtype`	Sempre; o token de evento da chave de definição.
`ce-subject`	Definido pela expressão específica do payload listada em cada contrato.
`ce-tenantid`	Sempre presente. O ID de tenant resolvido no escopo multi-tenant; o literal `default` no escopo single-tenant ou sem tenant.
`ce-schemaversion`	Sempre `1.0.0` para os 49 fatos JSON públicos.
`ce-datacontenttype`	`application/json`.

Tópicos, manifesto e roteamento

O tópico da aplicação identifica a aplicação produtora, não um evento individual. Roteie um registro por ce-resourcetype e ce-eventtype e valide ce-schemaversion antes de decodificar seu valor data.

Fatos: lerian.streaming.ledger
DLQ da rota: lerian.streaming.ledger.dlq
Manifesto: GET /v1/streaming/manifest expõe o catálogo JSON público e o mapeamento de tópicos, inclusive quando a publicação está desabilitada.

Semântica de entrega e falha

A publicação fica desabilitada até que STREAMING_ENABLED=true e a configuração de brokers tenha êxito. Quando habilitado, o Midaz emite depois da mudança de estado de negócio. Ele não conecta writer de outbox, repositório de outbox, outbox transacional nem relay de outbox da lib-streaming.

Política: toda definição JSON pública é um fact com entrega direta, tratamento de DLQ on_routable_failure e fallback_on_circuit_open configurado pela lib-streaming v3.
Limite real do Midaz: como nenhum writer de outbox está conectado, o fallback de circuito aberto não pode persistir um evento. Os caminhos de emissão registram e engolem erros de publicação em vez de devolvê-los ao comando de negócio.
Requisito do consumidor: a entrega do broker é pelo menos uma vez para registros publicados. Mantenha handlers idempotentes e deduplique com (ce-source, ce-id).

Plano legado separado do RabbitMQ

O Midaz também possui exchanges de compatibilidade para notificações selecionadas de transação, overdraft e auditoria. Eles são um plano legado separado do RabbitMQ, não um contrato da lib-streaming nem uma representação completa deste catálogo público de 49 eventos JSON. Novas integrações devem usar o contrato Kafka desta página.

Contratos completos de `data`

Estas declarações em estilo TypeScript espelham o formato wire do produtor. Todo nome de campo é seu nome JSON. ? significa que o campo tem omitempty; | null significa que o campo é anulável sem ser omitido. Um comentário de tipo de origem preserva exatamente o tipo do inventário. Valores decimais são strings JSON, nunca números binários de ponto flutuante.

Mapeamentos compartilhados de tipos de origem

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

Evento: studio.lerian.ledger.account.createdTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Uma conta é aberta em um ledger.Subject: ID da conta (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

Evento: studio.lerian.ledger.account.deletedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Uma conta é excluída.Subject: ID da conta (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

Evento: studio.lerian.ledger.account.updatedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Os campos mutáveis de uma conta mudam.Subject: ID da conta (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

Evento: studio.lerian.ledger.asset.createdTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um ativo é registrado em um ledger.Subject: ID do ativo (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

Evento: studio.lerian.ledger.asset.deletedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um ativo é excluído.Subject: ID do ativo (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

Evento: studio.lerian.ledger.asset.updatedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Os campos mutáveis de um ativo mudam.Subject: ID do ativo (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

Evento: studio.lerian.ledger.balance.changedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Uma transação confirmada move um saldo — um evento por operação que afeta o saldo; os valores refletem o estado após a operação.Subject: ID da transação e ID da operação (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

Evento: studio.lerian.ledger.balance.config_changedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: As configurações de um saldo mudam, ou o cheque especial é habilitado (o saldo acompanhante é materializado). changeType distingue settings_updated de overdraft_enabled.Subject: ID do saldo (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

Evento: studio.lerian.ledger.balance.createdTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um saldo é criado durante a configuração da conta.Subject: ID do saldo (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

Evento: studio.lerian.ledger.balance.deletedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um saldo é excluído.Subject: ID do saldo (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

Evento: studio.lerian.ledger.balance.overdraft_clearedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: O cheque especial é totalmente quitado — sinal terminal (action = cleared).Subject: ID da transação e ID da operação (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

Evento: studio.lerian.ledger.balance.overdraft_drawnTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um débito consome cheque especial além dos fundos disponíveis (action = drawn).Subject: ID da transação e ID da operação (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

Evento: studio.lerian.ledger.balance.overdraft_repaidTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: O uso do cheque especial diminui, mas não é totalmente quitado (action = repaid).Subject: ID da transação e ID da operação (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

Evento: studio.lerian.ledger.fee_billing_packages.createdTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um pacote de cobrança é criado.Subject: ID do pacote de cobrança (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

Evento: studio.lerian.ledger.fee_billing_packages.deletedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um pacote de cobrança é excluído.Subject: ID do pacote de cobrança (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

Evento: studio.lerian.ledger.fee_billing_packages.updatedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Os campos mutáveis de um pacote de cobrança mudam.Subject: ID do pacote de cobrança (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

Evento: studio.lerian.ledger.fee_charge.appliedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um pacote de tarifas é aplicado a uma transação confirmada.Subject: ID da transação (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

Evento: studio.lerian.ledger.fee_packages.createdTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um pacote de tarifas é criado.Subject: ID do pacote de tarifas (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

Evento: studio.lerian.ledger.fee_packages.deletedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um pacote de tarifas é excluído.Subject: ID do pacote de tarifas (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

Evento: studio.lerian.ledger.fee_packages.updatedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Os campos mutáveis de um pacote de tarifas mudam.Subject: ID do pacote de tarifas (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

Evento: studio.lerian.ledger.holder.createdTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um titular é criado.Subject: ID do titular (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

Evento: studio.lerian.ledger.holder.deletedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um titular é excluído.Subject: ID do titular (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

Evento: studio.lerian.ledger.holder.updatedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Os campos mutáveis de um titular mudam.Subject: ID do titular (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

Evento: studio.lerian.ledger.instrument.createdTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um instrumento é criado para um titular e uma conta.Subject: ID do instrumento (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

Evento: studio.lerian.ledger.instrument.deletedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um instrumento é excluído.Subject: ID do instrumento (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
}

Evento: studio.lerian.ledger.instrument.related_party_deletedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Uma única parte relacionada é removida de um instrumento (ce-subject é o id do instrumento).Subject: ID do instrumento (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

Evento: studio.lerian.ledger.instrument.updatedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Os campos mutáveis de um instrumento mudam.Subject: ID do instrumento (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

Evento: studio.lerian.ledger.ledger.createdTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um ledger é criado dentro de uma organização.Subject: ID do ledger (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

Evento: studio.lerian.ledger.ledger.deletedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um ledger é excluído.Subject: ID do ledger (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

Evento: studio.lerian.ledger.ledger.updatedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: O nome ou o status de um ledger muda.Subject: ID do ledger (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

Evento: studio.lerian.ledger.operation_route.createdTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Uma rota de operação é criada.Subject: ID da rota de operação (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

Evento: studio.lerian.ledger.operation_route.deletedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Uma rota de operação é excluída.Subject: ID da rota de operação (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

Evento: studio.lerian.ledger.operation_route.updatedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Os campos mutáveis de uma rota de operação mudam.Subject: ID da rota de operação (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

Evento: studio.lerian.ledger.organization.createdTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Uma organização é criada.Subject: ID da organização (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

Evento: studio.lerian.ledger.organization.deletedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Uma organização é excluída.Subject: ID da organização (p.ID)

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

organization.updated

Evento: studio.lerian.ledger.organization.updatedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Os campos mutáveis de uma organização mudam.Subject: ID da organização (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

Evento: studio.lerian.ledger.portfolio.createdTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um portfólio é criado.Subject: ID do portfólio (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

Evento: studio.lerian.ledger.portfolio.deletedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um portfólio é excluído.Subject: ID do portfólio (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

Evento: studio.lerian.ledger.portfolio.updatedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Os campos mutáveis de um portfólio mudam.Subject: ID do portfólio (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

Evento: studio.lerian.ledger.segment.createdTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um segmento é criado.Subject: ID do segmento (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

Evento: studio.lerian.ledger.segment.deletedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um segmento é excluído.Subject: ID do segmento (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

Evento: studio.lerian.ledger.segment.updatedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Os campos mutáveis de um segmento mudam.Subject: ID do segmento (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

Evento: studio.lerian.ledger.transaction.canceledTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Uma transação pendente passa de PENDING para CANCELED.Subject: ID da transação (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

Evento: studio.lerian.ledger.transaction.committedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Uma transação pendente passa de PENDING para APPROVED.Subject: ID da transação (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

Evento: studio.lerian.ledger.transaction.postedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Uma transação recém-criada é confirmada no armazenamento com todas as suas operações persistidas (sem pai).Subject: ID da transação (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

Evento: studio.lerian.ledger.transaction.revertedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Um fluxo de reversão cria uma transação filha; parentTransactionId a correlaciona com a original.Subject: ID da transação (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

Evento: studio.lerian.ledger.transaction_route.createdTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Uma rota de transação é criada.Subject: ID da rota de transação (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

Evento: studio.lerian.ledger.transaction_route.deletedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Uma rota de transação é excluída.Subject: ID da rota de transação (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

Evento: studio.lerian.ledger.transaction_route.updatedTópico: lerian.streaming.ledgerDLQ da rota: lerian.streaming.ledger.dlqSchema: 1.0.0Emitido quando: Os campos mutáveis de uma rota de transação mudam.Subject: ID da rota de transação (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
}

Evento interno de billing (fora do catálogo público)

billing_recorded é emitido separadamente dos 49 fatos JSON públicos. Ele usa Protobuf com framing Confluent, não o manifesto JSON público, e seu tópico fixo é lerian.streaming.billing.recorded. Não o conte como evento do manifesto nem o decodifique como os contratos JSON data acima. Ele preserva os cabeçalhos CloudEvents 1.0 com ce-source=ledger, ce-resourcetype=billing, ce-eventtype=recorded e ce-time definido como a data de criação da transação. Tipo CloudEvents: studio.lerian.ledger.billing.recorded Tópico: lerian.streaming.billing.recorded Tipo de conteúdo: application/vnd.confluent.protobuf Schema: 1.0.0 DLQ da rota: lerian.streaming.ledger.dlq Tenant: ce-tenantid segue a mesma regra de tenant resolvido ou literal default dos fatos públicos. Subject: ID da conta Emitido quando: Uma escrita de ciclo de vida não noop deixa a transação no status APPROVED; o Midaz emite um registro para cada conta não externa única referenciada por suas operações.

// 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
}

O Midaz preenche metric como active_account; properties.account_id e properties.transaction_id como strings; e subscription_id como o ID do tenant em modo multi-tenant ou o ID da organização da transação nos demais casos.

Visão geral

Midaz

Tracer

Lender

Matcher

Reporter

Fetcher

Consignado

Eventos do Midaz

Catálogo público JSON do ledger

Envelope CloudEvents

Tópicos, manifesto e roteamento

Semântica de entrega e falha

Plano legado separado do RabbitMQ

Contratos completos de `data`

Mapeamentos compartilhados de tipos de origem

Evento interno de billing (fora do catálogo público)

​Catálogo público JSON do ledger

​Envelope CloudEvents

​Tópicos, manifesto e roteamento

​Semântica de entrega e falha

​Plano legado separado do RabbitMQ

​Contratos completos de data

​Mapeamentos compartilhados de tipos de origem

​Evento interno de billing (fora do catálogo público)

Catálogo público JSON do ledger

Envelope CloudEvents

Tópicos, manifesto e roteamento

Semântica de entrega e falha

Plano legado separado do RabbitMQ

Contratos completos de `data`

Mapeamentos compartilhados de tipos de origem

Evento interno de billing (fora do catálogo público)