bgjob_metrics

Documentation

Index

• type Storage
  • func NewStorage(reg *metrics.Registry) *Storage
  • func (c *Storage) IncDlqCount(queue string, jobType string)
  • func (c *Storage) IncInternalErrorCount()
  • func (c *Storage) IncRetryCount(queue string, jobType string)
  • func (c *Storage) IncSuccessCount(queue string, jobType string)
  • func (c *Storage) ObserveExecuteDuration(queue string, jobType string, duration time.Duration)

Types

type Storage

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

func NewStorage

func NewStorage(reg *metrics.Registry) *Storage

func (*Storage) IncDlqCount

func (c *Storage) IncDlqCount(queue string, jobType string)

func (*Storage) IncInternalErrorCount

func (c *Storage) IncInternalErrorCount()

func (*Storage) IncRetryCount

func (c *Storage) IncRetryCount(queue string, jobType string)

func (*Storage) IncSuccessCount

func (c *Storage) IncSuccessCount(queue string, jobType string)

func (*Storage) ObserveExecuteDuration

func (c *Storage) ObserveExecuteDuration(queue string, jobType string, duration time.Duration)