metrics

type Config ¶

type Config struct {
	Handlers       []Handler
	Source         string
	Tags           map[string]string
	ReportInterval time.Duration
}

func LoadConfig(srcmap map[interface{}]interface{}) (*Config, error)

type Formatter ¶ added in v0.13.1

type Formatter interface {
	WriteTo(msg *metrics_pb.MetricsMessage, out io.Writer) error
}

type Gauge ¶ added in v0.14.23

type Gauge interface {
	metrics.Gauge
	Metric
}

Gauge represents a metric which is measuring a count and a rate

type Handler ¶

type Handler interface {
	// AcceptMetrics is called when new metrics become available
	AcceptMetrics(message *metrics_pb.MetricsMessage)
}

Handler represents a sink for metric events

func NewInfluxDBMetricsHandler(cfg *influxConfig) (Handler, error)

func NewOutputFileMetricsHandler(cfg *outputfileConfig) (Handler, error)

type HandlerType ¶

type HandlerType string

HandlerType is used to define known handler types

const (
	HandlerTypeInfluxDB HandlerType = "influxdb"
	HandlerTypeJSONFile HandlerType = "jsonfile"
	HandlerTypeFile     HandlerType = "file"
)

type Histogram ¶

type Histogram interface {
	Metric
	Clear()
	Update(int64)
}

Histogram represents a metric which is measuring the distribution of values for some measurement

type IntervalCounter ¶

type IntervalCounter interface {
	Metric
	Update(intervalId string, time time.Time, value uint64)
}

IntervalCounter allows tracking counters which are bucketized by some interval

type JsonFormatter ¶ added in v0.13.1

type JsonFormatter struct{}

func (formatter *JsonFormatter) WriteTo(msg *metrics_pb.MetricsMessage, out io.Writer) error

type LatencyHandler ¶ added in v0.15.10

type LatencyHandler interface {
	LatencyReported(latency time.Duration)
	ChannelClosed()
}

type LatencyProbeConfig ¶ added in v0.15.56

type LatencyProbeConfig struct {
	Channel        channel2.Channel
	Interval       time.Duration
	Timeout        time.Duration
	ResultHandler  func(resultNanos int64)
	TimeoutHandler func()
	ExitHandler    func()
}

type LatencyResponder ¶ added in v0.15.10

type LatencyResponder struct {
	// contains filtered or unexported fields
}

LatencyResponder responds to latency messages with LatencyResponse messages.

func (self *LatencyResponder) ContentType() int32

func (self *LatencyResponder) HandleReceive(msg *channel2.Message, _ channel2.Channel)

type Meter ¶

type Meter interface {
	Metric
	Mark(int64)
}

Meter represents a metric which is measuring a count and a rate

type Metric ¶

type Metric interface {
	Dispose()
}

Metric is the base functionality for all metrics types

type PlainTextFormatter ¶ added in v0.13.1

type PlainTextFormatter struct {
}

func (PlainTextFormatter) WriteTo(msg *metrics_pb.MetricsMessage, out io.Writer) error

type Registry ¶

type Registry interface {
	SourceId() string
	Gauge(name string) Gauge
	FuncGauge(name string, f func() int64) Gauge
	Meter(name string) Meter
	Histogram(name string) Histogram
	Timer(name string) Timer
	EachMetric(visitor func(name string, metric Metric))

	IsValidMetric(name string) bool
	Poll() *metrics_pb.MetricsMessage
	DisposeAll()
}

Registry allows for configuring and accessing metrics for a fabric application

func NewRegistry(sourceId string, tags map[string]string) Registry

type Timer ¶

type Timer interface {
	Metric
	Time(func())
	Update(time.Duration)
	UpdateSince(time.Time)
}

type UsageRegistry ¶ added in v0.13.1

type UsageRegistry interface {
	Registry
	IntervalCounter(name string, intervalSize time.Duration) IntervalCounter
	FlushToHandler(handler Handler)
	Flush()
	StartReporting(eventSink Handler, reportInterval time.Duration, msgQueueSize int)
}

UsageRegistry extends registry to allow collecting usage metrics

func NewUsageRegistry(sourceId string, tags map[string]string, closeNotify <-chan struct{}) UsageRegistry