server

Documentation

Index

• Constants
• Variables
• func NewAggregator(in chan *pb.Metric, out chan *pb.Metric, submissionCadence time.Duration) *aggregator
• func NewHistAggregator(name string, indexedLabels, unindexedLabels map[string]string) aggregatorUnit
• func NewSumAggregator(name string, indexedLabels, unindexedLabels map[string]string) aggregatorUnit
• func RunEndpoint(port int, ch chan *pb.Metric) error
• type Mux
  • func NewMux(in chan *pb.Metric) Mux
• type Plugin

Constants

const DIGITS_OF_PRECISION = 2

HdrHistogram doesn't store the values precisely, instead it maintains counts with a number of digits of precision requested.

const HIGHEST_VALUE = 1e7

const LOWEST_VALUE = 0

const MAIN_CHANNEL_BUFFER_SIZE = int(10e5)

Variables

var MUX_CHANNEL_BUFFER_SIZE = MAIN_CHANNEL_BUFFER_SIZE

Functions

func NewAggregator

func NewAggregator(
	in chan *pb.Metric,
	out chan *pb.Metric,
	submissionCadence time.Duration,
) *aggregator

Creates an instance of the aggregator, with in and out channels.

func NewHistAggregator

func NewHistAggregator(name string, indexedLabels, unindexedLabels map[string]string) aggregatorUnit

func NewSumAggregator

func NewSumAggregator(name string, indexedLabels, unindexedLabels map[string]string) aggregatorUnit

func RunEndpoint

func RunEndpoint(port int, ch chan *pb.Metric) error

RunEndpoint runs a metricd grpc endpoint on a given port, with all the reported Metrics submitted to the supplied channel.

Types

type Mux

type Mux interface {
	NewReceiver(receiverName string) chan *pb.Metric
	Run()
}

func NewMux

func NewMux(in chan *pb.Metric) Mux

type Plugin

type Plugin interface {
	// Runs the main plugin loop. Should be only called once,
	// in a separate goroutine. Never returns.
	Run()
}