diff --git a/sinks/gangliaSink.go b/sinks/gangliaSink.go index c53b11a..4a57d20 100644 --- a/sinks/gangliaSink.go +++ b/sinks/gangliaSink.go @@ -1,3 +1,5 @@ +//go:build ganglia + package sinks import ( diff --git a/sinks/gangliaSink_disabled.go b/sinks/gangliaSink_disabled.go new file mode 100644 index 0000000..84156d1 --- /dev/null +++ b/sinks/gangliaSink_disabled.go @@ -0,0 +1,31 @@ +//go:build !ganglia + +package sinks + +import ( + "encoding/json" + "errors" + + // "time" + + lp "github.com/ClusterCockpit/cc-metric-collector/internal/ccMetric" +) + +type GangliaSink struct { + sink +} + +func (s *GangliaSink) Init(config json.RawMessage) error { + return errors.New("sink 'ganglia' not implemented, rebuild with tag 'ganglia'") +} + +func (s *GangliaSink) Write(point lp.CCMetric) error { + return errors.New("sink 'ganglia' not implemented, rebuild with tag 'ganglia'") +} + +func (s *GangliaSink) Flush() error { + return errors.New("sink 'ganglia' not implemented, rebuild with tag 'ganglia'") +} + +func (s *GangliaSink) Close() { +} diff --git a/sinks/libgangliaSink.go b/sinks/libgangliaSink.go index f3490c6..7e03494 100644 --- a/sinks/libgangliaSink.go +++ b/sinks/libgangliaSink.go @@ -1,3 +1,5 @@ +//go:build ganglia + package sinks /* diff --git a/sinks/libgangliaSink_disabled.go b/sinks/libgangliaSink_disabled.go new file mode 100644 index 0000000..87ee75c --- /dev/null +++ b/sinks/libgangliaSink_disabled.go @@ -0,0 +1,29 @@ +//go:build !ganglia + +package sinks + +import ( + "encoding/json" + "errors" + + lp "github.com/ClusterCockpit/cc-metric-collector/internal/ccMetric" +) + +type LibgangliaSink struct { + sink +} + +func (s *LibgangliaSink) Init(config json.RawMessage) error { + return errors.New("sink 'libganglia' not implemented, rebuild with tag 'ganglia'") +} + +func (s *LibgangliaSink) Write(point lp.CCMetric) error { + return errors.New("sink 'libganglia' not implemented, rebuild with tag 'ganglia'") +} + +func (s *LibgangliaSink) Flush() error { + return errors.New("sink 'ganglia' not implemented, rebuild with tag 'ganglia'") +} + +func (s *LibgangliaSink) Close() { +}