queues

type ConsumeHandler func(ctx context.Context, payload []byte, entryID string, consumer QueueConsumer, log logrus.FieldLogger) error

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

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

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

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

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

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

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

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

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

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

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

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

type Provider interface {
	NewQueueConsumer(ctx context.Context, queueName string) (QueueConsumer, error)
	NewQueueProducer(ctx context.Context, queueName string) (QueueProducer, error)
	NewPubSubPublisher(ctx context.Context, channelName string) (PubSubPublisher, error)
	NewPubSubSubscriber(ctx context.Context, channelName string) (PubSubSubscriber, error)
	ProcessTimedOutMessages(ctx context.Context, queueName string, timeout time.Duration, handler func(entryID string, body []byte) error) (int, error)
	RetryFailedMessages(ctx context.Context, queueName string, config RetryConfig, handler func(entryID string, body []byte, retryCount int) error) (int, error)
	Stop()
	Wait()
	// CheckHealth verifies the provider is operational (e.g. Redis PING)
	CheckHealth(ctx context.Context) error
	// GetLatestProcessedTimestamp returns the latest timestamp that can be safely checkpointed
	// Returns the earliest in-flight task timestamp, or zero time if no in-flight tasks
	GetLatestProcessedTimestamp(ctx context.Context) (time.Time, error)
	// AdvanceCheckpointAndCleanup atomically advances the checkpoint by scanning in-flight tasks
	// and cleans up completed tasks before the checkpoint timestamp
	AdvanceCheckpointAndCleanup(ctx context.Context) error
	// SetCheckpointTimestamp sets the checkpoint to a specific timestamp (for recovery)
	SetCheckpointTimestamp(ctx context.Context, timestamp time.Time) error
}

type PubSubHandler func(ctx context.Context, payload []byte, log logrus.FieldLogger) error

type PubSubPublisher interface {
	Publish(ctx context.Context, payload []byte) error
	Close()
}

type PubSubSubscriber interface {
	Subscribe(ctx context.Context, handler PubSubHandler) (Subscription, error)
	Close()
}

type QueueConsumer interface {
	Consume(ctx context.Context, handler ConsumeHandler) error
	Complete(ctx context.Context, entryID string, body []byte, processingErr error) error
	Close()
}

type QueueProducer interface {
	Enqueue(ctx context.Context, payload []byte, timestamp int64) error
	Close()
}

type RetryConfig struct {
	BaseDelay    time.Duration // Base delay for exponential backoff
	MaxRetries   int           // Maximum number of retry attempts
	MaxDelay     time.Duration // Maximum delay cap
	JitterFactor float64       // Jitter factor (0.0 to 1.0)
}

type Subscription interface {
	Close()
}