Versions in this module Expand all Collapse all v1 v1.0.5 Dec 20, 2019 v1.0.4 Nov 20, 2019 v1.0.3 Sep 18, 2019 v1.0.2 Jul 23, 2019 Changes in this version type CseCollectorConfig + Env string type Reporter + func GetReporter() (*Reporter, error) + func (reporter *Reporter) Send(cb *hystrix.CircuitBreaker) v1.0.1 Jul 15, 2019 Changes in this version + func GetInterfaceName(metricName string) string v1.0.0 Apr 15, 2019 Changes in this version + const ContentType + const DefaultTimeout + const EnvProjectID + const HeaderDomainName + const HeaderUserName + const IdleConnsPerHost + const MetricsPath + const Name + const PostRemoteTimeout + var IsMonitoringConnected bool + var MetricServerPath = "" + func InitializeCseCollector(config *CseCollectorConfig, r metrics.Registry, ...) + func TransportFor(tlsconfig *tls.Config) http.RoundTripper + type CseCollectorConfig struct + CseMonitorAddr string + Header http.Header + TLSConfig *tls.Config + TimeInterval time.Duration + type CseMonitorClient struct + Client *httpclient.URLClient + Header http.Header + URL string + func NewCseMonitorClient(header http.Header, url string, tlsConfig *tls.Config, version string) (*CseMonitorClient, error) + func (cseMonitorClient *CseMonitorClient) PostMetrics(monitorData MonitorData) (err error) + type InterfaceInfo struct + CountTimeout int64 + Desc string + Failure int64 + FailureRate float64 + IsCircuitBreakerOpen bool + L25 int + L5 int + L50 int + L75 int + L90 int + L99 int + L995 int + Latency int + Name string + QPS float64 + Rate float64 + SemaphoreRejected int64 + ShortCircuited int64 + ThreadPoolRejected int64 + Total int64 + type MonitorData struct + AppID string + CPU float64 + Customs map[string]interface{} + Environment string + Instance string + InstanceID string + Interfaces []*InterfaceInfo + Memory map[string]interface{} + Name string + ServiceID string + Thread int + Version string + func NewMonitorData() *MonitorData + type Reporter struct + CseMonitorAddr string + Header http.Header + Interval time.Duration + Percentiles []float64 + Registry metrics.Registry + TLSConfig *tls.Config + func NewReporter(r metrics.Registry, addr string, header http.Header, interval time.Duration, ...) *Reporter + func (reporter *Reporter) Run()
Go to main page