metricsender

Documentation

Overview

Package metricsender contains functions for sending metrics from a state server to a remote metric collector.

Index

• func SendMetrics(st *state.State, sender MetricSender, batchSize int) error
• type DefaultSender
  • func (s *DefaultSender) Send(metrics []*wireformat.MetricBatch) (*wireformat.Response, error)
• type MetricSender
• type NopSender
  • func (n NopSender) Send(batches []*wireformat.MetricBatch) (*wireformat.Response, error)

Functions

func SendMetrics

func SendMetrics(st *state.State, sender MetricSender, batchSize int) error

SendMetrics will send any unsent metrics over the MetricSender interface in batches no larger than batchSize.

Types

type DefaultSender

type DefaultSender struct {
}

DefaultSender is the default used for sending metrics to the collector service.

func (*DefaultSender) Send

func (s *DefaultSender) Send(metrics []*wireformat.MetricBatch) (*wireformat.Response, error)

Send sends the given metrics to the collector service.

type MetricSender

type MetricSender interface {
	Send([]*wireformat.MetricBatch) (*wireformat.Response, error)
}

MetricSender defines the interface used to send metrics to a collection service.

type NopSender

type NopSender struct {
}

NopSender is a sender that acts like everything worked fine But doesn't do anything.

func (NopSender) Send

func (n NopSender) Send(batches []*wireformat.MetricBatch) (*wireformat.Response, error)

Implement the send interface, act like everything is fine.