metrics

Documentation

Index

• Variables
• type HubMetrics
  • func (hm *HubMetrics) AddProxyTrafficCollector(client, verb, resource, subresource string, size int)
  • func (hm *HubMetrics) DecClosableConns(server string)
  • func (hm *HubMetrics) DecErrorKeysCount()
  • func (hm *HubMetrics) DecInFlightRequests(verb, resource, subresource, client string)
  • func (hm *HubMetrics) IncClosableConns(server string)
  • func (hm *HubMetrics) IncErrorKeysCount()
  • func (hm *HubMetrics) IncInFlightRequests(verb, resource, subresource, client string)
  • func (hm *HubMetrics) IncRejectedRequestCounter()
  • func (hm *HubMetrics) ObserveServerHealthy(server string, status int)
  • func (hm *HubMetrics) ObserveYurtCoordinatorHealthyStatus(status int32)
  • func (hm *HubMetrics) ObserveYurtCoordinatorReadyStatus(status int32)
  • func (hm *HubMetrics) ObserveYurtCoordinatorYurthubRole(status int32)
  • func (hm *HubMetrics) Reset()
  • func (hm *HubMetrics) SetClosableConns(server string, cnt int)
  • func (hm *HubMetrics) SetErrorKeysPersistencyStatus(status int)
  • func (hm *HubMetrics) SetProxyLatencyCollector(client, verb, resource, subresource string, latencyType LatencyType, ...)
• type LatencyType

Variables

var (
	// Metrics provides access to all hub agent metrics.
	Metrics = newHubMetrics()
)

Types

type HubMetrics

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

func (*HubMetrics) AddProxyTrafficCollector

func (hm *HubMetrics) AddProxyTrafficCollector(client, verb, resource, subresource string, size int)

func (*HubMetrics) DecClosableConns

func (hm *HubMetrics) DecClosableConns(server string)

func (*HubMetrics) DecErrorKeysCount

func (hm *HubMetrics) DecErrorKeysCount()

func (*HubMetrics) DecInFlightRequests

func (hm *HubMetrics) DecInFlightRequests(verb, resource, subresource, client string)

func (*HubMetrics) IncClosableConns

func (hm *HubMetrics) IncClosableConns(server string)

func (*HubMetrics) IncErrorKeysCount

func (hm *HubMetrics) IncErrorKeysCount()

func (*HubMetrics) IncInFlightRequests

func (hm *HubMetrics) IncInFlightRequests(verb, resource, subresource, client string)

func (*HubMetrics) IncRejectedRequestCounter

func (hm *HubMetrics) IncRejectedRequestCounter()

func (*HubMetrics) ObserveServerHealthy

func (hm *HubMetrics) ObserveServerHealthy(server string, status int)

func (*HubMetrics) ObserveYurtCoordinatorHealthyStatus

func (hm *HubMetrics) ObserveYurtCoordinatorHealthyStatus(status int32)

func (*HubMetrics) ObserveYurtCoordinatorReadyStatus

func (hm *HubMetrics) ObserveYurtCoordinatorReadyStatus(status int32)

func (*HubMetrics) ObserveYurtCoordinatorYurthubRole

func (hm *HubMetrics) ObserveYurtCoordinatorYurthubRole(status int32)

func (*HubMetrics) Reset

func (hm *HubMetrics) Reset()

func (*HubMetrics) SetClosableConns

func (hm *HubMetrics) SetClosableConns(server string, cnt int)

func (*HubMetrics) SetErrorKeysPersistencyStatus

func (hm *HubMetrics) SetErrorKeysPersistencyStatus(status int)

func (*HubMetrics) SetProxyLatencyCollector

func (hm *HubMetrics) SetProxyLatencyCollector(client, verb, resource, subresource string, latencyType LatencyType, duration int64)

type LatencyType

type LatencyType string

const (
	// duration: yurthub -> apiserver
	Apiserver_latency LatencyType = "apiserver_latency"
	// duration: coming to yurthub -> yurthub to apiserver -> leaving yurthub
	Full_lantency LatencyType = "full_latency"
)