Counter is a InfluxStatsD counter. Observations are forwarded to a Influxstatsd object, and aggregated (summed) per timeseries.
type Counter struct {
// contains filtered or unexported fields
}
func (c *Counter) Add(delta float64)
Add implements metrics.Counter.
func (c *Counter) With(labelValues ...string) metrics.Counter
With implements metrics.Counter.
Gauge is a InfluxStatsD gauge. Observations are forwarded to a Influxstatsd object, and aggregated (the last observation selected) per timeseries.
type Gauge struct {
// contains filtered or unexported fields
}
func (g *Gauge) Add(delta float64)
Add implements metrics.Gauge.
func (g *Gauge) Set(value float64)
Set implements metrics.Gauge.
func (g *Gauge) With(labelValues ...string) metrics.Gauge
With implements metrics.Gauge.
Histogram is a InfluxStatsD histrogram. Observations are forwarded to a Influxstatsd object, and collected (but not aggregated) per timeseries.
type Histogram struct {
// contains filtered or unexported fields
}
func (h *Histogram) Observe(value float64)
Observe implements metrics.Histogram.
func (h *Histogram) With(labelValues ...string) metrics.Histogram
With implements metrics.Histogram.
Influxstatsd receives metrics observations and forwards them to a server. Create a Influxstatsd object, use it to create metrics, and pass those metrics as dependencies to the components that will use them.
All metrics are buffered until WriteTo is called. Counters and gauges are aggregated into a single observation per timeseries per write. Timings and histograms are buffered but not aggregated.
To regularly report metrics to an io.Writer, use the WriteLoop helper method. To send to a InfluxStatsD server, use the SendLoop helper method.
type Influxstatsd struct {
// contains filtered or unexported fields
}
func New(prefix string, logger log.Logger, lvs ...string) *Influxstatsd
New returns a Influxstatsd object that may be used to create metrics. Prefix is applied to all created metrics. Callers must ensure that regular calls to WriteTo are performed, either manually or with one of the helper methods.
func (d *Influxstatsd) NewCounter(name string, sampleRate float64) *Counter
NewCounter returns a counter, sending observations to this Influxstatsd object.
func (d *Influxstatsd) NewGauge(name string) *Gauge
NewGauge returns a gauge, sending observations to this Influxstatsd object.
func (d *Influxstatsd) NewHistogram(name string, sampleRate float64) *Histogram
NewHistogram returns a histogram whose observations are of an unspecified unit, and are forwarded to this Influxstatsd object.
func (d *Influxstatsd) NewTiming(name string, sampleRate float64) *Timing
NewTiming returns a histogram whose observations are interpreted as millisecond durations, and are forwarded to this Influxstatsd object.
func (d *Influxstatsd) SendLoop(ctx context.Context, c <-chan time.Time, network, address string)
SendLoop is a helper method that wraps WriteLoop, passing a managed connection to the network and address. Like WriteLoop, this method blocks until ctx is canceled, so clients probably want to start it in its own goroutine. For typical usage, create a time.Ticker and pass its C channel to this method.
func (d *Influxstatsd) WriteLoop(ctx context.Context, c <-chan time.Time, w io.Writer)
WriteLoop is a helper method that invokes WriteTo to the passed writer every time the passed channel fires. This method blocks until ctx is canceled, so clients probably want to run it in its own goroutine. For typical usage, create a time.Ticker and pass its C channel to this method.
func (d *Influxstatsd) WriteTo(w io.Writer) (count int64, err error)
WriteTo flushes the buffered content of the metrics to the writer, in InfluxStatsD format. WriteTo abides best-effort semantics, so observations are lost if there is a problem with the write. Clients should be sure to call WriteTo regularly, ideally through the WriteLoop or SendLoop helper methods.
Timing is a InfluxStatsD timing, or metrics.Histogram. Observations are forwarded to a Influxstatsd object, and collected (but not aggregated) per timeseries.
type Timing struct {
// contains filtered or unexported fields
}
func (t *Timing) Observe(value float64)
Observe implements metrics.Histogram. Value is interpreted as milliseconds.
func (t *Timing) With(labelValues ...string) metrics.Histogram
With implements metrics.Timing.