metric

Documentation

Index

• Constants
• func MetricsToPrometheusStrings(metrics map[string]exportedMetric, labels []prometheusKeyValuePair) []string
• func NewNtpReporter(ctx context.Context, metricFactory Factory, logger log.Logger, ...) govnr.ShutdownWaiter
• func NewRegistry() *inMemoryRegistry
• func NewRuntimeReporter(ctx context.Context, metricFactory Factory, logger log.Logger) govnr.ShutdownWaiter
• func NewSystemReporter(ctx context.Context, metricFactory Factory, logger log.Logger) govnr.ShutdownWaiter
• type Factory
• type Gauge
  • func (g *Gauge) Add(i int64)
  • func (g *Gauge) AddUint32(i uint32)
  • func (g *Gauge) Dec()
  • func (g *Gauge) Export() exportedMetric
  • func (g *Gauge) Inc()
  • func (m *Gauge) Name() string
  • func (g *Gauge) String() string
  • func (g *Gauge) SubUint32(size uint32)
  • func (g *Gauge) Update(i int64)
  • func (g *Gauge) UpdateUInt32(i int32)
  • func (g *Gauge) Value() int64
• type Histogram
  • func (h *Histogram) Export() exportedMetric
  • func (m *Histogram) Name() string
  • func (h *Histogram) Record(measurement int64)
  • func (h *Histogram) RecordSince(t time.Time)
  • func (h *Histogram) Rotate()
  • func (h *Histogram) String() string
• type Rate
  • func (r *Rate) Export() exportedMetric
  • func (r *Rate) Measure(eventCount int64)
  • func (m *Rate) Name() string
  • func (r *Rate) Reset()
  • func (r *Rate) String() string
• type Registry
• type Text
  • func (t *Text) Export() exportedMetric
  • func (m *Text) Name() string
  • func (t *Text) String() string
  • func (t *Text) Update(value string)
  • func (t *Text) Value() string

Constants

const AGGREGATION_SPAN = 10 * time.Minute

const NTP_QUERY_INTERVAL = 30 * time.Second

const PAGESIZE = 4096

const ROTATE_INTERVAL = 30 * time.Second

const RUNTIME_QUERY_INTERVAL = 5 * time.Second

Functions

func MetricsToPrometheusStrings

func MetricsToPrometheusStrings(metrics map[string]exportedMetric, labels []prometheusKeyValuePair) []string

func NewNtpReporter

func NewNtpReporter(ctx context.Context, metricFactory Factory, logger log.Logger, ntpServerAddress string) govnr.ShutdownWaiter

func NewRegistry

func NewRegistry() *inMemoryRegistry

func NewRuntimeReporter

func NewRuntimeReporter(ctx context.Context, metricFactory Factory, logger log.Logger) govnr.ShutdownWaiter

func NewSystemReporter

func NewSystemReporter(ctx context.Context, metricFactory Factory, logger log.Logger) govnr.ShutdownWaiter

Types

type Factory

type Factory interface {
	NewHistogram(name string, maxValue int64) *Histogram
	NewLatency(name string, maxDuration time.Duration) *Histogram
	NewGauge(name string) *Gauge
	NewRate(name string) *Rate
	NewText(name string, defaultValue ...string) *Text
}

type Gauge

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

func (*Gauge) Add

func (g *Gauge) Add(i int64)

func (*Gauge) AddUint32

func (g *Gauge) AddUint32(i uint32)

func (*Gauge) Dec

func (g *Gauge) Dec()

func (*Gauge) Export

func (g *Gauge) Export() exportedMetric

func (*Gauge) Inc

func (g *Gauge) Inc()

func (*Gauge) Name

func (m *Gauge) Name() string

func (*Gauge) String

func (g *Gauge) String() string

func (*Gauge) SubUint32

func (g *Gauge) SubUint32(size uint32)

func (*Gauge) Update

func (g *Gauge) Update(i int64)

func (*Gauge) UpdateUInt32

func (g *Gauge) UpdateUInt32(i int32)

func (*Gauge) Value

func (g *Gauge) Value() int64

type Histogram

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

func (*Histogram) Export

func (h *Histogram) Export() exportedMetric

func (*Histogram) Name

func (m *Histogram) Name() string

func (*Histogram) Record

func (h *Histogram) Record(measurement int64)

func (*Histogram) RecordSince

func (h *Histogram) RecordSince(t time.Time)

func (*Histogram) Rotate

func (h *Histogram) Rotate()

func (*Histogram) String

func (h *Histogram) String() string

type Rate

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

func (*Rate) Export

func (r *Rate) Export() exportedMetric

func (*Rate) Measure

func (r *Rate) Measure(eventCount int64)

func (*Rate) Name

func (m *Rate) Name() string

func (*Rate) Reset

func (r *Rate) Reset()

func (*Rate) String

func (r *Rate) String() string

type Registry

type Registry interface {
	Factory
	String() string
	ExportAll() map[string]exportedMetric
	PeriodicallyRotate(ctx context.Context, logger log.Logger) govnr.ShutdownWaiter
	ExportPrometheus() string
	WithVirtualChainId(id primitives.VirtualChainId) Registry
	WithNodeAddress(nodeAddress primitives.NodeAddress) Registry
	Remove(metric metric)
	Get(metricName string) metric
}

type Text

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

func (*Text) Export

func (t *Text) Export() exportedMetric

func (*Text) Name

func (m *Text) Name() string

func (*Text) String

func (t *Text) String() string

func (*Text) Update

func (t *Text) Update(value string)

func (*Text) Value

func (t *Text) Value() string