outboxpgx

type Config struct {
	// TableName is the outbox table. Default: "outbox_messages".
	TableName string
	// ClientID is stored in every row's client_id column. May be empty. The
	// outbox processor does not read it.
	ClientID string
	// ClientCode is the client's identifier slug, sent as clientCode in
	// event and audit payloads so the platform attributes them to that
	// client. The platform refuses a code the credential cannot reach (403
	// for the whole batch); empty leaves it out, and the platform then scopes
	// by the credential (an anchor writes platform-scoped events, a
	// single-client credential its own client). A domain event implementing
	// outbox.ClientCoded overrides it.
	ClientCode string
	// AuditEnabled writes audit log rows alongside every event. The
	// platform always audits its control plane writes; consumer apps
	// should only enable this for admin / human-initiated operations,
	// not for every transactional event.
	AuditEnabled bool
	// ApplicationCode, when set, is written as each audit row's
	// applicationCode, attributing it to the application. The platform
	// requires it when the credential the outbox processor uses is
	// application-scoped (an application's own service account), and
	// refuses the row otherwise.
	ApplicationCode string
	// Now is the clock for created_at/updated_at. Default time.Now.
	Now func() time.Time
}

type Sink struct {
	// contains filtered or unexported fields
}