package model import ( "encoding/json" "time" ) type OutboxEvent struct { ID string `db:"id" json:"id"` AggregateType string `db:"aggregate_type" json:"aggregate_type"` AggregateID string `db:"aggregate_id" json:"aggregate_id"` AggregateVersion int64 `db:"aggregate_version" json:"aggregate_version"` EventType string `db:"event_type" json:"event_type"` Payload json.RawMessage `db:"payload" json:"payload"` CreatedAt time.Time `db:"created_at" json:"created_at"` ProcessedAt *time.Time `db:"processed_at" json:"processed_at"` } func (OutboxEvent) TableName() string { return "veyra_outbox_event" }