Fountain

English

Tiếng Việt

English

Tiếng Việt

Appearance

Import path: gitlab.soludian.com/soludian/fountain/libs/metrics/graphite

graphite ​

go
import "gitlab.soludian.com/soludian/fountain/libs/metrics/graphite"

Index ​

Variables ​

go
var KPackageName = "graphite"

type Counter ​

Counter is a Graphite counter metric.

go
type Counter struct {
    // contains filtered or unexported fields
}

func NewCounter ​

go
func NewCounter(name string) *Counter

NewCounter returns a new usable counter metric.

func (*Counter) Add ​

go
func (c *Counter) Add(delta float64)

Add implements counter.

func (*Counter) With ​

go
func (c *Counter) With(...string) metrics.Counter

With is a no-op.

type Gauge ​

Gauge is a Graphite gauge metric.

go
type Gauge struct {
    // contains filtered or unexported fields
}

func NewGauge ​

go
func NewGauge(name string) *Gauge

NewGauge returns a new usable Gauge metric.

func (*Gauge) Add ​

go
func (g *Gauge) Add(delta float64)

Add implements metrics.Gauge.

func (*Gauge) Set ​

go
func (g *Gauge) Set(value float64)

Set implements gauge.

func (*Gauge) With ​

go
func (g *Gauge) With(...string) metrics.Gauge

With is a no-op.

type Graphite ​

Graphite receives metrics observations and forwards them to a Graphite server. Create a Graphite 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 time series per write. Histograms are exploded into per-quantile gauges and reported once per write.

To regularly report metrics to an io.Writer, use the WriteLoop helper method. To send to a Graphite server, use the SendLoop helper method.

go
type Graphite struct {
    // contains filtered or unexported fields
}

func New ​

go
func New(prefix string, logger flog.FlogInf) *Graphite

New returns a Graphite 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 (*Graphite) NewCounter ​

go
func (g *Graphite) NewCounter(name string) *Counter

NewCounter returns a counter. Observations are aggregated and emitted once per write invocation.

func (*Graphite) NewGauge ​

go
func (g *Graphite) NewGauge(name string) *Gauge

NewGauge returns a gauge. Observations are aggregated and emitted once per write invocation.

func (*Graphite) NewHistogram ​

go
func (g *Graphite) NewHistogram(name string, buckets int) *Histogram

NewHistogram returns a histogram. Observations are aggregated and emitted as per-quantile gauges, once per write invocation. 50 is a good default value for buckets.

func (*Graphite) SendLoop ​

go
func (g *Graphite) 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 (*Graphite) WriteLoop ​

go
func (g *Graphite) 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 (*Graphite) WriteTo ​

go
func (g *Graphite) WriteTo(w io.Writer) (count int64, err error)

WriteTo flushes the buffered content of the metrics to the writer, in Graphite plaintext 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.

type Histogram ​

Histogram is a Graphite histogram metric. Observations are bucketed into per-quantile gauges.

go
type Histogram struct {
    // contains filtered or unexported fields
}

func NewHistogram ​

go
func NewHistogram(name string, buckets int) *Histogram

NewHistogram returns a new usable Histogram metric.

func (*Histogram) Observe ​

go
func (h *Histogram) Observe(value float64)

Observe implements histogram.

func (*Histogram) With ​

go
func (h *Histogram) With(...string) metrics.Histogram

With is a no-op.

Generated by gomarkdoc