queue

Documentation

Index

• type AlertQueue
  • func NewAlertQueue(log *logrus.Logger, ...) *AlertQueue
• type Metrics
  • func NewMetrics(namespace string) *Metrics
• type Queue
  • func NewQueue[T any](log *logrus.Logger, worker func(context.Context, T) (bool, error), ...) *Queue[T]
  • func (q *Queue[T]) Enqueue(item T)
  • func (q *Queue[T]) SetWorker(worker func(context.Context, T) (bool, error))
  • func (q *Queue[T]) Start(ctx context.Context)
  • func (q *Queue[T]) Stop(ctx context.Context)
• type Queuer

Types

type AlertQueue

type AlertQueue struct {
	*Queue[*store.MonitorAlert]
}

AlertQueue is a concrete queue type for MonitorAlerts.

func NewAlertQueue

func NewAlertQueue(log *logrus.Logger, worker func(context.Context, *store.MonitorAlert) (bool, error), metrics *Metrics) *AlertQueue

NewAlertQueue creates a new alert queue.

type Metrics

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

func NewMetrics

func NewMetrics(namespace string) *Metrics

type Queue

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

Queue is a generic queue for processing items.

func NewQueue

func NewQueue[T any](log *logrus.Logger, worker func(context.Context, T) (bool, error), metrics *Metrics) *Queue[T]

NewQueue creates a new queue.

func (*Queue[T]) Enqueue

func (q *Queue[T]) Enqueue(item T)

func (*Queue[T]) SetWorker

func (q *Queue[T]) SetWorker(worker func(context.Context, T) (bool, error))

SetWorker sets the worker function for processing items.

func (*Queue[T]) Start

func (q *Queue[T]) Start(ctx context.Context)

func (*Queue[T]) Stop

func (q *Queue[T]) Stop(ctx context.Context)

Stop stops the queue processor.

type Queuer

type Queuer interface {
	Start(ctx context.Context)
	Stop(ctx context.Context)
}

Queuer defines the interface for queue operations.