Documentation
¶
Overview ¶
Package metricsender contains functions for sending metrics from a controller to a remote metric collector.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultMaxBatchesPerSend ¶
func DefaultMaxBatchesPerSend() int
DefaultMaxBatchesPerSend returns the default number of batches per send.
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.
func ToWire ¶
func ToWire(mb *state.MetricBatch) *wireformat.MetricBatch
ToWire converts the state.MetricBatch into a type that can be sent over the wire to the collector.
Types ¶
type HttpSender ¶
type HttpSender struct {
}
HttpSender is the default used for sending metrics to the collector service.
func (*HttpSender) Send ¶
func (s *HttpSender) 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.
func DefaultMetricSender ¶
func DefaultMetricSender() MetricSender
DefaultMetricSender returns the default metric sender.
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.
Source Files
Directories