internal

Documentation

Index

• type MetricReporter
• type ServerMetricReporter
  • func (smr *ServerMetricReporter) DequeuedEvent(subsystem, identifier string)
  • func (smr *ServerMetricReporter) EnqueuedEvent(subsystem, identifier string)
  • func (smr *ServerMetricReporter) SetMetrics(subsystem, identifier string, size int, bufferSize int)
• type SharedQueueMetricReporter
  • func (sqmr *SharedQueueMetricReporter) DequeuedEvent(subsystem, identifier string)
  • func (sqmr *SharedQueueMetricReporter) EnqueuedEvent(subsystem, identifier string)
  • func (sqmr *SharedQueueMetricReporter) SetMetrics(subsystem, identifier string, size int, bufferSize int)

Types

type MetricReporter

type MetricReporter interface {
	SetMetrics(subsystem, identifier string, size int, bufferSize int)
	EnqueuedEvent(subsystem, identifier string)
	DequeuedEvent(subsystem, identifier string)
}

type ServerMetricReporter

type ServerMetricReporter struct{}

ServerMetricReporter is used for inmemory queues (queue per server)

func (*ServerMetricReporter) DequeuedEvent

func (smr *ServerMetricReporter) DequeuedEvent(subsystem, identifier string)

func (*ServerMetricReporter) EnqueuedEvent

func (smr *ServerMetricReporter) EnqueuedEvent(subsystem, identifier string)

func (*ServerMetricReporter) SetMetrics

func (smr *ServerMetricReporter) SetMetrics(subsystem, identifier string, size int, bufferSize int)

type SharedQueueMetricReporter

type SharedQueueMetricReporter struct{}

SharedQueueMetricReporter is used for shared queues e.g. Redis (1 queue for all servers)

func (*SharedQueueMetricReporter) DequeuedEvent

func (sqmr *SharedQueueMetricReporter) DequeuedEvent(subsystem, identifier string)

func (*SharedQueueMetricReporter) EnqueuedEvent

func (sqmr *SharedQueueMetricReporter) EnqueuedEvent(subsystem, identifier string)

func (*SharedQueueMetricReporter) SetMetrics

func (sqmr *SharedQueueMetricReporter) SetMetrics(subsystem, identifier string, size int, bufferSize int)