From 5da14042f70711ea5cf66e034699730335462f66 Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sun, 5 May 2024 14:08:03 +0200 Subject: Merging upstream version 1.45.3+dfsg. Signed-off-by: Daniel Baumann --- .../go.d.plugin/modules/activemq/init.go | 32 ++++++++++++++++++++++ 1 file changed, 32 insertions(+) create mode 100644 src/go/collectors/go.d.plugin/modules/activemq/init.go (limited to 'src/go/collectors/go.d.plugin/modules/activemq/init.go') diff --git a/src/go/collectors/go.d.plugin/modules/activemq/init.go b/src/go/collectors/go.d.plugin/modules/activemq/init.go new file mode 100644 index 000000000..43cdb2e95 --- /dev/null +++ b/src/go/collectors/go.d.plugin/modules/activemq/init.go @@ -0,0 +1,32 @@ +// SPDX-License-Identifier: GPL-3.0-or-later + +package activemq + +import ( + "errors" + "github.com/netdata/netdata/go/go.d.plugin/pkg/matcher" +) + +func (a *ActiveMQ) validateConfig() error { + if a.URL == "" { + return errors.New("url not set") + } + if a.Webadmin == "" { + return errors.New("webadmin root path set") + } + return nil +} + +func (a *ActiveMQ) initQueuesFiler() (matcher.Matcher, error) { + if a.QueuesFilter == "" { + return matcher.TRUE(), nil + } + return matcher.NewSimplePatternsMatcher(a.QueuesFilter) +} + +func (a *ActiveMQ) initTopicsFilter() (matcher.Matcher, error) { + if a.TopicsFilter == "" { + return matcher.TRUE(), nil + } + return matcher.NewSimplePatternsMatcher(a.TopicsFilter) +} -- cgit v1.2.3