txoutbox

type ClaimInput struct {
	Consumer  string
	Now       time.Time
	Limit     int
	Topic     string
	LockUntil *time.Time
}

type DispatchInput struct {
	Consumer    string
	Topic       string
	Limit       int
	Now         time.Time
	RetryDelay  time.Duration
	ClaimLockTo *time.Time
}

type DispatchResult struct {
	Claimed   int
	Published int
	Retrying  int
	Failed    int
}

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

type Message struct {
	ID            string
	TenantID      string
	OrgID         string
	Topic         string
	MessageKey    string
	PayloadJSON   string
	HeadersJSON   string
	CorrelationID string
	Status        string
	AttemptCount  int
	MaxAttempts   int
	LastError     string
	AvailableAt   time.Time
	LockedAt      *time.Time
	LockedBy      string
	PublishedAt   *time.Time
	CreatedAt     time.Time
	UpdatedAt     time.Time
}

type PostCommitHook func() error

type Publisher interface {
	PublishOutboxMessage(ctx context.Context, message Message) error
}

type Query struct {
	Topic    string
	Status   string
	Limit    int
	Offset   int
	SortDesc bool
}

type Store[Scope any] interface {
	EnqueueOutboxMessage(ctx context.Context, scope Scope, record Message) (Message, error)
	ClaimOutboxMessages(ctx context.Context, scope Scope, input ClaimInput) ([]Message, error)
	MarkOutboxMessageSucceeded(ctx context.Context, scope Scope, id string, publishedAt time.Time) (Message, error)
	MarkOutboxMessageFailed(ctx context.Context, scope Scope, id, failureReason string, nextAttemptAt *time.Time, failedAt time.Time) (Message, error)
	ListOutboxMessages(ctx context.Context, scope Scope, query Query) ([]Message, error)
}

type TxManager[Tx any] interface {
	WithTx(ctx context.Context, fn func(tx Tx) error) error
}