Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + func CompressWithGzip(data io.Reader) (io.Reader, error) + func NewReportWrite(capacity int) *reportWrite + type BulkAction struct + func (b *BulkAction) Push(request Metrics) error + type BulkMetricRequest []*Metric + func CreateBulkMetricRequest() *BulkMetricRequest + func (b *BulkMetricRequest) Add(name string, tags map[string]string, fields map[string]interface{}) *BulkMetricRequest + func (b *BulkMetricRequest) AddWithTime(name string, tags map[string]string, fields map[string]interface{}, ...) *BulkMetricRequest + type CollectorConfig struct + Addr string + Password string + Retry int + UserName string + type Disruptor interface + In func(metrics ...*Metric) error + type GlobalLabel map[string]string + type Metric struct + Fields map[string]interface{} + Name string + Tags map[string]string + Timestamp int64 + type MetricReport interface + CreateReportClient func(addr, username, password string) *ReportClient + Send func(in []*Metric) error + SetCFG func(cfg *config) + type Metrics []*Metric + type NamedMetrics struct + Metrics Metrics + Name string + type ReportClient struct + CFG *config + HttpClient *http.Client + func (c *ReportClient) CreateReportClient(addr, username, password string) *ReportClient + func (c *ReportClient) Send(in []*Metric) error + func (c *ReportClient) SetCFG(cfg *config) + type ReportConfig struct + BufferSize int + Collector CollectorConfig + Mode string + UdpHost string + UdpPort string + type ReportMode string + type Reporter interface + Send func(metrics []*Metric) error
Go to main page