outbox

type AuditDataProvider interface {
	AuditData() any
}

type AuditOperationNamer interface {
	AuditOperation() string
}

type ClientCoded interface {
	ClientCode() string
}

type Config struct {
	// ClientID is stored in every row's client_id column (the outbox
	// processor does not read it; it is for the application's own
	// partitioning). May be empty.
	ClientID string
	// ClientCode is the client's identifier slug, written as clientCode in
	// event and audit payloads so the platform attributes them to that
	// client (a domain event implementing ClientCoded overrides it). Empty
	// leaves it out: the platform then scopes by the credential (an anchor
	// writes platform-scoped rows, a single-client credential its client).
	ClientCode string
	// ApplicationCode is written as each audit row's applicationCode. The
	// platform requires it of an application-scoped credential.
	ApplicationCode string
	// Now is the clock for created_at/updated_at. Default time.Now.
	Now func() time.Time
}

type DispatchJob struct {
	// ID is the job id, [0-9A-Za-z_-]{1,17}; generated (a 13-character TSID)
	// when empty. It is in the payload, so a batch the processor sends again
	// creates a job with the same id.
	ID        string
	Kind      string // EVENT or TASK; default TASK
	Code      string // {application}:{rest}, at most 255 characters
	Source    string // default: the code's application segment
	Subject   string
	TargetURL string // absolute http(s) URL with a host and no user info

	// Payload is the body delivered to TargetURL, with PayloadContentType.
	// Default: {} as application/json.
	Payload            string
	PayloadContentType string
	DataOnly           bool

	ExternalID    string
	EventID       string
	CorrelationID string

	// PlatformClientID is the platform's client id (never a slug). ClientCode
	// is the client's identifier slug, which the platform resolves at ingest
	// (an unknown code refuses the whole batch: 400 for an anchor, 403
	// otherwise). Set at most one; without either the job has no client.
	PlatformClientID string
	ClientCode       string

	SubscriptionID   string
	ServiceAccountID string
	DispatchPoolID   string
	MessageGroup     string
	Mode             string // IMMEDIATE, NEXT_ON_ERROR or BLOCK_ON_ERROR
	// Sequence, TimeoutSeconds and MaxRetries are at least 1 when set (the
	// platform turns 0 into its default, so 0 cannot be sent); nil leaves
	// them to the platform (99, 30 and 3).
	Sequence       *int
	TimeoutSeconds *int
	MaxRetries     *int
	Metadata       []MetadataEntry
	Queue          string // DEFAULT or HIGH_PRIORITY
	Descriptor     string
	// contains filtered or unexported fields
}

type MetadataEntry struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type Placeholder int

type Row struct {
	ID           string
	Type         string
	MessageGroup string
	Payload      []byte
	ClientID     string
	CreatedAt    time.Time
}