From 767523889996a1ae3b96c74f8ad461a6002ec5c8 Mon Sep 17 00:00:00 2001 From: Thomas Roehl Date: Wed, 16 Feb 2022 18:27:49 +0100 Subject: [PATCH] Add build tag 'ganglia' and create corresponding files --- sinks/gangliaSink.go | 2 ++ sinks/gangliaSink_disabled.go | 31 +++++++++++++++++++++++++++++++ sinks/libgangliaSink.go | 2 ++ sinks/libgangliaSink_disabled.go | 29 +++++++++++++++++++++++++++++ 4 files changed, 64 insertions(+) create mode 100644 sinks/gangliaSink_disabled.go create mode 100644 sinks/libgangliaSink_disabled.go 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() { +}