metric

Documentation

Index

• Constants
• func TypeTag(metricType string) map[string]string
• func ValueField(metricValue interface{}) map[string]interface{}
• type Collector
• type DefaultRequestMetric
• type Metric
  • func NewTypeValueMetric(name string, metricType string, metricValue interface{}, timestamp time.Time) *Metric

Constants

const DefaultMetricError = "error"

Functions

func TypeTag

func TypeTag(metricType string) map[string]string

func ValueField

func ValueField(metricValue interface{}) map[string]interface{}

Types

type Collector

type Collector interface {
	// When cancelC is closed, collector needs to start closing.
	// After cancelC is closed, metricC is subsequently closed,
	// collector needs to close doneC after completing the closing work.
	Start(cancelC <-chan struct{}, metricC <-chan *Metric) (doneC <-chan struct{})
}

type DefaultRequestMetric

type DefaultRequestMetric string

const (
	DefaultRequestMetricDNSLookup         DefaultRequestMetric = "dns_lookup"
	DefaultRequestMetricTCPConnection     DefaultRequestMetric = "tcp_connection"
	DefaultRequestMetricTLSHandshake      DefaultRequestMetric = "tls_handshake"
	DefaultRequestMetricWaitingConnection DefaultRequestMetric = "waiting_connection"
	DefaultRequestMetricSending           DefaultRequestMetric = "sending"
	DefaultRequestMetricWaitingServer     DefaultRequestMetric = "waiting_server"
	DefaultRequestMetricReceiving         DefaultRequestMetric = "receiving"
	DefaultRequestMetricRequestsNumber    DefaultRequestMetric = "requests_number"
)

type Metric

type Metric struct {
	Name      string
	Tags      map[string]string
	Fields    map[string]interface{}
	Timestamp time.Time
}

func NewTypeValueMetric

func NewTypeValueMetric(name string, metricType string, metricValue interface{}, timestamp time.Time) *Metric