queue

type AlertQueue ¶

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

AlertQueue is a concrete queue type for MonitorAlerts.

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

type Metrics ¶

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

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[T any](log *logrus.Logger, worker func(context.Context, T) (bool, error), metrics *Metrics) *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 ¶

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

Queuer defines the interface for queue operations.