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
• func RegisterConfigIndicators(metricRegistry Registry, nodeConfig config.NodeConfig)
• 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

func RegisterConfigIndicators

func RegisterConfigIndicators(metricRegistry Registry, nodeConfig config.NodeConfig)

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)
}

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