Versions in this module Expand all Collapse all v0 v0.6.7 Dec 4, 2023 Changes in this version type HttpSinkConfig + Password string + Username string v0.6.6 Aug 29, 2023 v0.6.5 Mar 20, 2023 v0.6.4 Dec 20, 2022 v0.6.3 Dec 14, 2022 v0.6.2 Oct 13, 2022 v0.6.1 Jul 12, 2022 v0.6.0 Jun 9, 2022 Changes in this version type HttpSinkConfig + MaxRetries int type NatsSinkConfig + FlushDelay string + Subject string v0.5.1 Apr 4, 2022 Changes in this version + const DEFAULT_GANGLIA_METRIC_SLOPE + const DEFAULT_GANGLIA_METRIC_TMAX + const GANGLIA_LIB_DL_FLAGS + const GANGLIA_LIB_NAME + const GMETRIC_CONFIG + const GMETRIC_EXEC + const GMOND_CONFIG_FILE + const SINK_MAX_FORWARD + var AvailableSinks = map[string]func(name string, config json.RawMessage) (Sink, error) + var CommonGangliaMetrics = []GangliaMetricGroup + func GangliaMetricName(point lp.CCMetric) string + func GangliaMetricRename(name string) string + func GangliaSlopeType(point lp.CCMetric) uint + type GangliaMetric struct + Name string + Slope string + Tmax int + Type string + Unit string + type GangliaMetricConfig struct + Group string + Name string + Slope string + Tmax int + Type string + Unit string + Value string + func GetCommonGangliaConfig(point lp.CCMetric) GangliaMetricConfig + func GetGangliaConfig(point lp.CCMetric) GangliaMetricConfig + type GangliaMetricGroup struct + Metrics []GangliaMetric + Name string + type GangliaSink struct + func (s *GangliaSink) Close() + func (s *GangliaSink) Flush() error + func (s *GangliaSink) Name() string + func (s *GangliaSink) Write(point lp.CCMetric) error + type GangliaSinkConfig struct + AddGangliaGroup bool + AddTagsAsDesc bool + AddTypeToName bool + AddUnits bool + ClusterName string + GmetricConfig string + GmetricPath string + type HttpSink struct + func (s *HttpSink) Close() + func (s *HttpSink) Flush() error + func (s *HttpSink) Name() string + func (s *HttpSink) Write(m lp.CCMetric) error + type HttpSinkConfig struct + FlushDelay string + IdleConnTimeout string + JWT string + MaxIdleConns int + Timeout string + URL string + type InfluxAsyncSink struct + func (s *InfluxAsyncSink) Close() + func (s *InfluxAsyncSink) Flush() error + func (s *InfluxAsyncSink) Name() string + func (s *InfluxAsyncSink) Write(m lp.CCMetric) error + type InfluxAsyncSinkConfig struct + BatchSize uint + CustomFlushInterval string + Database string + FlushInterval uint + Host string + InfluxExponentialBase uint + InfluxMaxRetries uint + InfluxMaxRetryTime string + InfluxRetryInterval string + MaxRetryAttempts uint + Organization string + Password string + Port string + RetentionPol string + SSL bool + User string + type InfluxSink struct + func (s *InfluxSink) Close() + func (s *InfluxSink) Flush() error + func (s *InfluxSink) Name() string + func (s *InfluxSink) Write(m lp.CCMetric) error + type InfluxSinkConfig struct + BatchSize int + Database string + FlushDelay string + Host string + Organization string + Password string + Port string + RetentionPol string + SSL bool + User string + type LibgangliaSink struct + func (s *LibgangliaSink) Close() + func (s *LibgangliaSink) Flush() error + func (s *LibgangliaSink) Name() string + func (s *LibgangliaSink) Write(point lp.CCMetric) error + type LibgangliaSinkConfig struct + AddGangliaGroup bool + AddTypeToName bool + AddUnits bool + ClusterName string + GangliaLib string + GmondConfig string + type NatsSink struct + func (s *NatsSink) Close() + func (s *NatsSink) Flush() error + func (s *NatsSink) Name() string + func (s *NatsSink) Write(m lp.CCMetric) error + type NatsSinkConfig struct + Database string + Host string + Password string + Port string + User string + type PrometheusSink struct + func (s *PrometheusSink) Close() + func (s *PrometheusSink) Flush() error + func (s *PrometheusSink) Name() string + func (s *PrometheusSink) Write(m lp.CCMetric) error + type PrometheusSinkConfig struct + GroupAsNameSpace bool + Host string + Path string + Port string + type SampleSink struct + func (s *SampleSink) Close() + func (s *SampleSink) Flush() error + func (s *SampleSink) Name() string + func (s *SampleSink) Write(point lp.CCMetric) error + type SampleSinkConfig struct + type Sink interface + Close func() + Flush func() error + Name func() string + Write func(point lp.CCMetric) error + func NewGangliaSink(name string, config json.RawMessage) (Sink, error) + func NewHttpSink(name string, config json.RawMessage) (Sink, error) + func NewInfluxAsyncSink(name string, config json.RawMessage) (Sink, error) + func NewInfluxSink(name string, config json.RawMessage) (Sink, error) + func NewLibgangliaSink(name string, config json.RawMessage) (Sink, error) + func NewNatsSink(name string, config json.RawMessage) (Sink, error) + func NewPrometheusSink(name string, config json.RawMessage) (Sink, error) + func NewSampleSink(name string, config json.RawMessage) (Sink, error) + func NewStdoutSink(name string, config json.RawMessage) (Sink, error) + type SinkManager interface + AddInput func(input chan lp.CCMetric) + AddOutput func(name string, config json.RawMessage) error + Close func() + Init func(wg *sync.WaitGroup, sinkConfigFile string) error + Start func() + func New(wg *sync.WaitGroup, sinkConfigFile string) (SinkManager, error) + type StdoutSink struct + func (s *StdoutSink) Close() + func (s *StdoutSink) Flush() error + func (s *StdoutSink) Name() string + func (s *StdoutSink) Write(m lp.CCMetric) error