worker

Documentation

Index

• type WorkerCollector
  • func NewWorkerCollector(ctx context.Context, log logrus.FieldLogger, cfg *config.Config, ...) *WorkerCollector
  • func (c *WorkerCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *WorkerCollector) DecMessagesInProgress()
  • func (c *WorkerCollector) Describe(ch chan<- *prometheus.Desc)
  • func (c *WorkerCollector) IncMessageRetries()
  • func (c *WorkerCollector) IncMessagesInProgress()
  • func (c *WorkerCollector) IncMessagesProcessed(status string)
  • func (c *WorkerCollector) IncPermanentFailures()
  • func (c *WorkerCollector) IncRetryableFailures()
  • func (c *WorkerCollector) IncTasksByType(taskType string)
  • func (c *WorkerCollector) MetricsName() string
  • func (c *WorkerCollector) ObserveProcessingDuration(duration time.Duration)
  • func (c *WorkerCollector) ObserveTaskExecutionDuration(taskType string, duration time.Duration)
  • func (c *WorkerCollector) SetConsumersActive(count float64)
  • func (c *WorkerCollector) SetQueueDepth(queue string, depth float64)
  • func (c *WorkerCollector) SetRedisConnectionStatus(connected bool)
  • func (c *WorkerCollector) UpdateLastSuccessfulTask()

Types

type WorkerCollector

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

WorkerCollector implements NamedCollector and gathers worker-related metrics.

func NewWorkerCollector

func NewWorkerCollector(ctx context.Context, log logrus.FieldLogger, cfg *config.Config, queuesProvider queues.Provider) *WorkerCollector

NewWorkerCollector creates a WorkerCollector.

func (*WorkerCollector) Collect

func (c *WorkerCollector) Collect(ch chan<- prometheus.Metric)

func (*WorkerCollector) DecMessagesInProgress

func (c *WorkerCollector) DecMessagesInProgress()

func (*WorkerCollector) Describe

func (c *WorkerCollector) Describe(ch chan<- *prometheus.Desc)

func (*WorkerCollector) IncMessageRetries

func (c *WorkerCollector) IncMessageRetries()

func (*WorkerCollector) IncMessagesInProgress

func (c *WorkerCollector) IncMessagesInProgress()

func (*WorkerCollector) IncMessagesProcessed

func (c *WorkerCollector) IncMessagesProcessed(status string)

func (*WorkerCollector) IncPermanentFailures

func (c *WorkerCollector) IncPermanentFailures()

func (*WorkerCollector) IncRetryableFailures

func (c *WorkerCollector) IncRetryableFailures()

func (*WorkerCollector) IncTasksByType

func (c *WorkerCollector) IncTasksByType(taskType string)

func (*WorkerCollector) MetricsName

func (c *WorkerCollector) MetricsName() string

func (*WorkerCollector) ObserveProcessingDuration

func (c *WorkerCollector) ObserveProcessingDuration(duration time.Duration)

func (*WorkerCollector) ObserveTaskExecutionDuration

func (c *WorkerCollector) ObserveTaskExecutionDuration(taskType string, duration time.Duration)

func (*WorkerCollector) SetConsumersActive

func (c *WorkerCollector) SetConsumersActive(count float64)

func (*WorkerCollector) SetQueueDepth

func (c *WorkerCollector) SetQueueDepth(queue string, depth float64)

func (*WorkerCollector) SetRedisConnectionStatus

func (c *WorkerCollector) SetRedisConnectionStatus(connected bool)

func (*WorkerCollector) UpdateLastSuccessfulTask

func (c *WorkerCollector) UpdateLastSuccessfulTask()