jobqueue

type Config struct {
	Logger      logger.StandardLogger
	MaxWorkers  uint
	MaxRetries  uint
	MaxTimeout  time.Duration
	ExtendDelay time.Duration
	// contains filtered or unexported fields
}

type DedupQueueConfig struct {
	DedupeEnabled     *bool
	BlockRepeatsOnDLQ *bool
	HashFunc          dedup.HashFunc
}

type JobQueue[T any] struct {
	// contains filtered or unexported fields
}

type Option func(c *Config) error

type QueueProvider struct {
	Setup func(context.Context, *sql.DB) error
	New   func(name string, db *sql.DB, opts QueueProviderOpts) (queue.Interface, error)
}

type QueueProviderOpts struct {
	MaxReceive int
	Timeout    time.Duration
	Logger     logger.StandardLogger
}

type Service[T any] interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	Register(name string, fn func(context.Context, T) error, opts ...worker.JobOption[T]) error
	RegisterHandler(handler TaskHandler[T], opts ...worker.JobOption[T]) error
	Enqueue(ctx context.Context, name string, msg T) error
}

type TaskHandler[T any] interface {
	Handle(ctx context.Context, payload T) error
	Name() string
}