monitoring

Documentation

Index

• type MetricService
  • func NewMetricService(servers servers.Repository, instances instances.Repository, ...) *MetricService
  • func (ms *MetricService) GetRegistry() *prometheus.Registry
  • func (ms *MetricService) Observe(ctx context.Context, config ObserverConfig)
• type ObserverConfig

Types

type MetricService

type MetricService struct {
	ReporterRequests  *prometheus.CounterVec
	ReporterErrors    *prometheus.CounterVec
	ReporterReceived  prometheus.Counter
	ReporterSent      prometheus.Counter
	ReporterRemovals  prometheus.Counter
	ReporterDurations *prometheus.HistogramVec
	BrowserRequests   prometheus.Counter
	BrowserErrors     prometheus.Counter
	BrowserReceived   prometheus.Counter
	BrowserSent       prometheus.Counter
	BrowserDurations  prometheus.Histogram

	CleanerRemovals prometheus.Counter
	CleanerErrors   prometheus.Counter

	DiscoveryWorkersBusy      prometheus.Gauge
	DiscoveryWorkersAvailable prometheus.Gauge
	DiscoveryQueueProduced    prometheus.Counter
	DiscoveryQueueConsumed    prometheus.Counter
	DiscoveryQueueExpired     prometheus.Counter
	DiscoveryProbes           *prometheus.CounterVec
	DiscoveryProbeSuccess     *prometheus.CounterVec
	DiscoveryProbeRetries     *prometheus.CounterVec
	DiscoveryProbeFailures    *prometheus.CounterVec
	DiscoveryProbeErrors      *prometheus.CounterVec
	DiscoveryProbeDurations   *prometheus.HistogramVec
	DiscoveryQueryDurations   prometheus.Histogram

	ServerRepositorySize   prometheus.Gauge
	InstanceRepositorySize prometheus.Gauge
	ProbeRepositorySize    prometheus.Gauge

	GameDiscoveredServers *prometheus.GaugeVec
	GameActiveServers     *prometheus.GaugeVec
	GamePlayedServers     *prometheus.GaugeVec
	GamePlayers           *prometheus.GaugeVec
	// contains filtered or unexported fields
}

func NewMetricService

func NewMetricService(
	servers servers.Repository,
	instances instances.Repository,
	probes probes.Repository,
	clock clock.Clock,
	logger *zerolog.Logger,
) *MetricService

func (*MetricService) GetRegistry

func (ms *MetricService) GetRegistry() *prometheus.Registry

func (*MetricService) Observe

func (ms *MetricService) Observe(
	ctx context.Context,
	config ObserverConfig,
)

type ObserverConfig

type ObserverConfig struct {
	ServerLiveness time.Duration
}