inbox

type AttemptStart struct {
	Record    Record
	Decision  StartDecision
	Delay     time.Duration
	Reclaimed bool
}

type DBProvider func(context.Context) *gorm.DB

type Delivery struct {
	EventID         string
	SourceTopic     string
	BrokerMessageID string
	Payload         string
	MessageMetadata map[string]string
}

type ExecuteOptions struct {
	MaxAttempts       int
	InitialBackoff    time.Duration
	MaxBackoff        time.Duration
	BackoffMultiplier float64
	ProcessingLease   time.Duration
	OnReclaim         func(ctx context.Context, record Record)
	OnRetry           func(ctx context.Context, record Record, delay time.Duration, cause error)
	OnSuccess         func(ctx context.Context, record Record)
	OnSkip            func(ctx context.Context, record Record)
	OnDeadLetter      func(ctx context.Context, record Record) error
}

type ExecuteResult struct {
	Outcome     Outcome
	Record      Record
	Reclaimed   bool
	Attempted   int
	DeadLetter  bool
	LastBackoff time.Duration
}

type MySQLSchema struct {
	TableName string
}

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

type Outcome string

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

type Record struct {
	ID              int64
	ConsumerName    string
	EventID         string
	SourceTopic     string
	Payload         string
	MessageMetadata map[string]string
	BrokerMessageID string
	PayloadHash     string
	Status          string
	AttemptCount    int32
	MaxAttempts     int32
	NextAttemptAt   time.Time
	LeaseExpiresAt  time.Time
	LastError       string
	DeadLetteredAt  time.Time
	FinishedAt      time.Time
	CreatedAt       time.Time
	UpdatedAt       time.Time
}

type StartDecision string

type Store interface {
	StartAttempt(
		ctx context.Context,
		consumerName string,
		delivery Delivery,
		payloadHash string,
		maxAttempts int,
		lease time.Duration,
	) (AttemptStart, error)
	MarkSucceeded(ctx context.Context, id int64, finishedAt time.Time) error
	MarkRetrying(ctx context.Context, id int64, lastError string, nextAttemptAt time.Time) error
	MarkDeadLettered(ctx context.Context, id int64, lastError string, deadLetteredAt time.Time) error
	Get(ctx context.Context, consumerName string, eventID string) (Record, error)
}