outbox

Aug 11, 2026

Changes in this version

+ func CancelByKey(tx *sql.Tx, cancelKey string) error

+ func CancelForProject(tx *sql.Tx, projectId uuid.UUID) error

+ func DrainOnce(ctx context.Context, now time.Time)

+ func Enqueue(tx *sql.Tx, d Delivery) (int, error)

+ func PageCancelKey(pageId int) string

+ func RegisterSender(fn SendFunc)

+ func RegisterTerminalHook(fn TerminalHook)

+ func StartDrain(ctx context.Context)

+ func VerificationCancelKey(methodId int) string

+ func Wake()

+ type Delivery struct

+ AdapterConfig json.RawMessage

+ AdapterType string

+ CancelKey string

+ ChannelName string

+ Kind string

+ Message models.NotificationMessage

+ NotBefore *time.Time

+ PageNotificationId *int

+ ProjectId *uuid.UUID

+ RuleId *int

+ type HealthStats struct

+ FailedRows int

+ OldestPendingAgeSec int64

+ Pending int

+ Sending int

+ SentTotal uint64

+ TerminalFailuresTotal uint64

+ func HealthSnapshot() (*HealthStats, error)

+ type SendFunc func(ctx context.Context, adapterType string, adapterConfig json.RawMessage, ...) error

+ type TerminalHook func(row *models.OutboxDelivery, status string, errorMsg string)