Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
EOS = errors.New("End Of Stream")
)
Functions ¶
func CopyMetrics ¶
func CopyMetrics(dst MetricWriter, src MetricReader) error
Types ¶
type Metric ¶
type MetricBuffer ¶
type MetricBuffer struct { Events chan Event // contains filtered or unexported fields }
func NewMetricBuffer ¶
func NewMetricBuffer(n int) *MetricBuffer
func (*MetricBuffer) Close ¶
func (eq *MetricBuffer) Close()
func (*MetricBuffer) ReadMetric ¶
func (eq *MetricBuffer) ReadMetric() (Metric, error)
func (*MetricBuffer) WriteMetrics ¶
func (eq *MetricBuffer) WriteMetrics(ms []Metric) error
type MetricCloser ¶
type MetricCloser interface {
Close()
}
type MetricReadCloser ¶
type MetricReadCloser interface { MetricReader MetricCloser }
func NewMetricPoller ¶
func NewMetricPoller(interval time.Duration, fn PollFunc) MetricReadCloser
func NewMultiMetricReader ¶
func NewMultiMetricReader(rs ...MetricReader) MetricReadCloser
type MetricReader ¶
type MetricTags ¶
type MetricTags []MetricTag
func (MetricTags) String ¶
func (ts MetricTags) String() string
type MetricWriter ¶
type MultiMetricWriter ¶
type MultiMetricWriter struct {
// contains filtered or unexported fields
}
MultiMetricWriter is a writer which forwards the received events to multiple writers
func NewMultiMetricWriter ¶
func NewMultiMetricWriter(writers ...MetricWriter) *MultiMetricWriter
NewMultiMetricWriter creates a new MultiMetricWriter instance
func (*MultiMetricWriter) AddWriter ¶
func (m *MultiMetricWriter) AddWriter(writer MetricWriter)
AddWriter registers a new writer
func (*MultiMetricWriter) WriteMetrics ¶
func (m *MultiMetricWriter) WriteMetrics(metrics []Metric) error
WriteMetrics forwards the received events to the registered writers
type PollFunc ¶
type PollFunc func(MetricWriter) error
Click to show internal directories.
Click to hide internal directories.