monitoring

Documentation

Index

• type ClientsHealthResponse
• type Counters
  • func NewCounters() *Counters
• type Server
  • func NewServer(metricServers []config.MetricServer, port int, failureThreshold int) *Server
  • func (m *Server) OnError(c client.Interface, metricType config.MetricType, err error)
  • func (m *Server) Start()
  • func (m *Server) UpdateCustomMetrics(c client.Interface, cms map[provider.CustomMetricInfo]struct{})
  • func (m *Server) UpdateExternalMetrics(c client.Interface, ems map[provider.ExternalMetricInfo]struct{})

Types

type ClientsHealthResponse

type ClientsHealthResponse struct {
	ClientFailures *Counters `json:"consecutiveFailures,omitempty"`
	ClientOk       *Counters `json:"successTotal,omitempty"`
}

type Counters

type Counters struct {
	CustomMetrics   map[string]int `json:"customMetrics,omitempty"`
	ExternalMetrics map[string]int `json:"externalMetrics,omitempty"`
}

func NewCounters

func NewCounters() *Counters

type Server

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

func NewServer

func NewServer(metricServers []config.MetricServer, port int, failureThreshold int) *Server

func (*Server) OnError

func (m *Server) OnError(c client.Interface, metricType config.MetricType, err error)

func (*Server) Start

func (m *Server) Start()

func (*Server) UpdateCustomMetrics

func (m *Server) UpdateCustomMetrics(c client.Interface, cms map[provider.CustomMetricInfo]struct{})

func (*Server) UpdateExternalMetrics

func (m *Server) UpdateExternalMetrics(c client.Interface, ems map[provider.ExternalMetricInfo]struct{})