Versions in this module Expand all Collapse all v1 v1.0.0 Mar 17, 2017 Changes in this version + const ClientVersion + const DefaultReportingDelay + const DefaultTimeout + const EventIngestEndpointV2 + const IngestEndpointV2 + const TokenHeaderName + var DefaultBucketWidth = time.Second * 20 + var DefaultErrorHandler = func(err error) error + var DefaultHistogramSize = 80 + var DefaultMaxBufferSize = 100 + var DefaultQuantiles = []float64 + var DefaultUserAgent = fmt.Sprintf("golib-sfxclient/%s (gover %s)", ClientVersion, runtime.Version()) + func Counter(metricName string, dimensions map[string]string, val int64) *datapoint.Datapoint + func Cumulative(metricName string, dimensions map[string]string, val int64) *datapoint.Datapoint + func CumulativeF(metricName string, dimensions map[string]string, val float64) *datapoint.Datapoint + func CumulativeP(metricName string, dimensions map[string]string, val *int64) *datapoint.Datapoint + func Gauge(metricName string, dimensions map[string]string, val int64) *datapoint.Datapoint + func GaugeF(metricName string, dimensions map[string]string, val float64) *datapoint.Datapoint + type Collector interface + Datapoints func() []*datapoint.Datapoint + var GoMetricsSource Collector = &goMetrics{} + func NewMultiCollector(collectors ...Collector) Collector + type CumulativeBucket struct + Dimensions map[string]string + MetricName string + func (b *CumulativeBucket) Add(val int64) + func (b *CumulativeBucket) Datapoints() []*datapoint.Datapoint + func (b *CumulativeBucket) MultiAdd(res *Result) + type HTTPSink struct + AuthToken string + Client http.Client + DatapointEndpoint string + EventEndpoint string + UserAgent string + func NewHTTPSink() *HTTPSink + func (h *HTTPSink) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) (err error) + func (h *HTTPSink) AddEvents(ctx context.Context, events []*event.Event) (err error) + type HashableCollector struct + Callback func() []*datapoint.Datapoint + func CollectorFunc(callback func() []*datapoint.Datapoint) *HashableCollector + func (h *HashableCollector) Datapoints() []*datapoint.Datapoint + type MultiCollector []Collector + func (m MultiCollector) Datapoints() []*datapoint.Datapoint + type Result struct + Count int64 + Sum int64 + SumOfSquares float64 + func (r *Result) Add(val int64) + type RollingBucket struct + BucketWidth time.Duration + Dimensions map[string]string + Hist *gohistogram.NumericHistogram + MaxFlushBufferSize int + MetricName string + Quantiles []float64 + Timer timekeeper.TimeKeeper + func NewRollingBucket(metricName string, dimensions map[string]string) *RollingBucket + func (r *RollingBucket) Add(v float64) + func (r *RollingBucket) AddAt(v float64, t time.Time) + func (r *RollingBucket) Datapoints() []*datapoint.Datapoint + type Scheduler struct + ErrorHandler func(error) error + ReportingDelayNs int64 + SendZeroTime bool + Sink Sink + Timer timekeeper.TimeKeeper + func NewScheduler() *Scheduler + func (s *Scheduler) AddCallback(db Collector) + func (s *Scheduler) AddGroupedCallback(group string, db Collector) + func (s *Scheduler) DefaultDimensions(dims map[string]string) + func (s *Scheduler) GroupedDefaultDimensions(group string, dims map[string]string) + func (s *Scheduler) RemoveCallback(db Collector) + func (s *Scheduler) RemoveGroupedCallback(group string, db Collector) + func (s *Scheduler) ReportOnce(ctx context.Context) error + func (s *Scheduler) ReportingDelay(delay time.Duration) + func (s *Scheduler) Schedule(ctx context.Context) error + func (s *Scheduler) Var() expvar.Var + type Sink interface + AddDatapoints func(ctx context.Context, points []*datapoint.Datapoint) (err error) + type TimeCounter struct + Above int64 + Below int64 + NsBarrier int64 + func (t *TimeCounter) Add(dur time.Duration) + func (t *TimeCounter) Collector(metric string) Collector + type WithDimensions struct + Collector Collector + Dimensions map[string]string + func (w *WithDimensions) Datapoints() []*datapoint.Datapoint