queuepoller

type Handler ¶

type Handler[Job any] interface {
	// contains filtered or unexported methods
}

Handler processes jobs of the given type.

func BatchJobHandler[Job any](handler func(ctx context.Context, jobs []WithID[Job]) map[string]error) Handler[Job]

func JobHandler[Job any](handler func(ctx context.Context, j Job) error) Handler[Job]

type Option ¶

type Option func(*config)

Option configures the CachingQueuePoller

func WithConcurrency(concurrency int) Option

func WithJobBatchSize(size int) Option

type Queue ¶

type Queue[Job any] interface {
	QueueQueuer[Job]
	QueueReader[Job]
	QueueReleaser
	QueueDeleter
}

Queue is an interface for a job queue, combining queuing, reading, releasing, and deleting jobs.

type QueueDeleter ¶

type QueueDeleter interface {
	Delete(ctx context.Context, jobID string) error
}

QueueDeleter is an interface for deleting jobs from the queue.

type QueuePoller ¶

type QueuePoller[Job any] struct {
	// contains filtered or unexported fields
}

QueuePoller polls a queue for jobs and processes them using the provided JobHandler.

func NewQueuePoller[Job any](queue Queue[Job], handler Handler[Job], opts ...Option) (*QueuePoller[Job], error)

func (p *QueuePoller[Job]) Start()

func (p *QueuePoller[Job]) Stop()

type QueueQueuer ¶

type QueueQueuer[Job any] interface {
	Queue(ctx context.Context, job Job) error
}

QueueQueuer is an interface for queuing jobs.

type QueueReader ¶

type QueueReader[Job any] interface {
	Read(ctx context.Context, maxJobs int) ([]WithID[Job], error)
}

QueueReader is an interface for reading jobs from the queue.

type QueueReleaser ¶

type QueueReleaser interface {
	Release(ctx context.Context, jobID string) error
}

QueueReleaser is an interface for releasing jobs from the queue.

type WithID ¶

type WithID[Job any] struct {
	ID  string
	Job Job
}