Versions in this module Expand all Collapse all v2 v2.5.1 Feb 18, 2026 v2.5.0 Feb 18, 2026 v2.4.0 Feb 12, 2026 v2.3.0 Feb 10, 2026 v2.2.2 Feb 10, 2026 v2.2.1 Jan 27, 2026 v2.2.0 Jan 26, 2026 v2.1.0 Jan 14, 2026 v2.0.0 Dec 24, 2025 Changes in this version + const DEFAULT_GANGLIA_METRIC_SLOPE — linux/amd64 + const DEFAULT_GANGLIA_METRIC_TMAX — linux/amd64 + const GANGLIA_LIB_DL_FLAGS — linux/amd64 + const GANGLIA_LIB_NAME — linux/amd64 + const GMETRIC_CONFIG — linux/amd64 + const GMETRIC_EXEC — linux/amd64 + const GMOND_CONFIG_FILE — linux/amd64 + const SINK_MAX_FORWARD + var AvailableSinks = map[string]func(name string, config json.RawMessage) (Sink, error) + var CommonGangliaMetrics = []GangliaMetricGroup — linux/amd64 + func EncoderAdd(encoder *influx.Encoder, msg lp.CCMessage) error + func GangliaMetricName(point lp.CCMessage) string — linux/amd64 + func GangliaMetricRename(name string) string — linux/amd64 + func GangliaSlopeType(point lp.CCMessage) uint — linux/amd64 + type GangliaMetric struct — linux/amd64 + Name string + Slope string + Tmax int + Type string + Unit string + type GangliaMetricConfig struct — linux/amd64 + Group string + Name string + Slope string + Tmax int + Type string + Unit string + Value string + func GetCommonGangliaConfig(point lp.CCMessage) GangliaMetricConfig + func GetGangliaConfig(point lp.CCMessage) GangliaMetricConfig + type GangliaMetricGroup struct — linux/amd64 + Metrics []GangliaMetric + Name string + type GangliaSink struct — linux/amd64 + func (s *GangliaSink) Close() + func (s *GangliaSink) Flush() error + func (s *GangliaSink) Name() string + func (s *GangliaSink) Write(msg lp.CCMessage) error + type GangliaSinkConfig struct — linux/amd64 + 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(msg lp.CCMessage) error + type HttpSinkConfig struct + FlushDelay string + IdleConnTimeout string + JWT string + MaxRetries int + Password string + Precision string + Timeout string + URL string + Username string + type InfluxAsyncSink struct + func (s *InfluxAsyncSink) Close() + func (s *InfluxAsyncSink) Flush() error + func (s *InfluxAsyncSink) Name() string + func (s *InfluxAsyncSink) Write(m lp.CCMessage) 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 + Precision 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(msg lp.CCMessage) error + type LibgangliaSink struct — linux/amd64 + func (s *LibgangliaSink) Close() + func (s *LibgangliaSink) Flush() error + func (s *LibgangliaSink) Name() string + func (s *LibgangliaSink) Write(msg lp.CCMessage) error + type LibgangliaSinkConfig struct — linux/amd64 + 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.CCMessage) error + type NatsSinkConfig struct + FlushDelay string + Host string + NkeyFile string + Password string + Port string + Precision string + Subject 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.CCMessage) 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.CCMessage) error + type SampleSinkConfig struct + type Sink interface + Close func() + Flush func() error + Name func() string + Write func(point lp.CCMessage) 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.CCMessage) + AddOutput func(name string, config json.RawMessage) error + Close func() + Init func(wg *sync.WaitGroup, sinkConfig json.RawMessage) error + Start func() + func New(wg *sync.WaitGroup, sinkConfig json.RawMessage) (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.CCMessage) error Other modules containing this package github.com/ClusterCockpit/cc-lib
Go to main page