Versions in this module Expand all Collapse all v0 v0.7.1 Aug 16, 2018 v0.5.1 May 31, 2018 Changes in this version + const DM_Attempts + const DM_CircuitOpen + const DM_Errors + const DM_Failures + const DM_FallbackFailures + const DM_FallbackSuccesses + const DM_Rejects + const DM_RunDuration + const DM_ShortCircuits + const DM_Successes + const DM_Timeouts + const DM_TotalDuration + const GigabitStatsdFlushBytes + const LANStatsdFlushBytes + const WANStatsdFlushBytes + func InitializeGraphiteCollector(config *GraphiteCollectorConfig) + func NewDatadogCollector(addr, prefix string) (func(string) metricCollector.MetricCollector, error) + func NewDatadogCollectorWithClient(client DatadogClient) func(string) metricCollector.MetricCollector + func NewGraphiteCollector(name string) metricCollector.MetricCollector + type DatadogClient interface + Count func(name string, value int64, tags []string, rate float64) error + Gauge func(name string, value float64, tags []string, rate float64) error + TimeInMilliseconds func(name string, value float64, tags []string, rate float64) error + type DatadogCollector struct + func (dc *DatadogCollector) IncrementAttempts() + func (dc *DatadogCollector) IncrementErrors() + func (dc *DatadogCollector) IncrementFailures() + func (dc *DatadogCollector) IncrementFallbackFailures() + func (dc *DatadogCollector) IncrementFallbackSuccesses() + func (dc *DatadogCollector) IncrementRejects() + func (dc *DatadogCollector) IncrementShortCircuits() + func (dc *DatadogCollector) IncrementSuccesses() + func (dc *DatadogCollector) IncrementTimeouts() + func (dc *DatadogCollector) Reset() + func (dc *DatadogCollector) UpdateRunDuration(runDuration time.Duration) + func (dc *DatadogCollector) UpdateTotalDuration(timeSinceStart time.Duration) + type GraphiteCollector struct + func (g *GraphiteCollector) IncrementAttempts() + func (g *GraphiteCollector) IncrementErrors() + func (g *GraphiteCollector) IncrementFailures() + func (g *GraphiteCollector) IncrementFallbackFailures() + func (g *GraphiteCollector) IncrementFallbackSuccesses() + func (g *GraphiteCollector) IncrementRejects() + func (g *GraphiteCollector) IncrementShortCircuits() + func (g *GraphiteCollector) IncrementSuccesses() + func (g *GraphiteCollector) IncrementTimeouts() + func (g *GraphiteCollector) Reset() + func (g *GraphiteCollector) UpdateRunDuration(runDuration time.Duration) + func (g *GraphiteCollector) UpdateTotalDuration(timeSinceStart time.Duration) + type GraphiteCollectorConfig struct + GraphiteAddr *net.TCPAddr + Prefix string + TickInterval time.Duration + type StatsdCollector struct + func (g *StatsdCollector) IncrementAttempts() + func (g *StatsdCollector) IncrementErrors() + func (g *StatsdCollector) IncrementFailures() + func (g *StatsdCollector) IncrementFallbackFailures() + func (g *StatsdCollector) IncrementFallbackSuccesses() + func (g *StatsdCollector) IncrementRejects() + func (g *StatsdCollector) IncrementShortCircuits() + func (g *StatsdCollector) IncrementSuccesses() + func (g *StatsdCollector) IncrementTimeouts() + func (g *StatsdCollector) Reset() + func (g *StatsdCollector) UpdateRunDuration(runDuration time.Duration) + func (g *StatsdCollector) UpdateTotalDuration(timeSinceStart time.Duration) + type StatsdCollectorClient struct + func InitializeStatsdCollector(config *StatsdCollectorConfig) (*StatsdCollectorClient, error) + func (s *StatsdCollectorClient) NewStatsdCollector(name string) metricCollector.MetricCollector + type StatsdCollectorConfig struct + FlushBytes int + Prefix string + SampleRate float32 + StatsdAddr string