fix: add plugin log level

pkg/plugin/exporter.go

@@ -137,7 +137,7 @@ func (e *ExportPluginSystem) Load(ctx context.Context) error {
 			Logger: hclog.New(&hclog.LoggerOptions{
 				Name:       "exporter",
 				Output:     os.Stdout,
-				Level:      hclog.Debug,
+				Level:      getLogLevel(),
 				JSONFormat: true,
 			}),
 		})

pkg/plugin/log.go

@@ -0,0 +1,23 @@
+package plugin
+
+import (
+	"github.com/hashicorp/go-hclog"
+	"github.com/re-cinq/aether/pkg/config"
+)
+
+// getLogLevel is a helper function to get the log level from the config
+func getLogLevel() hclog.Level {
+	level := config.AppConfig().LogLevel
+	switch level {
+	case "debug":
+		return hclog.Debug
+	case "info":
+		return hclog.Info
+	case "warn":
+		return hclog.Warn
+	case "error":
+		return hclog.Error
+	default:
+		return hclog.Info
+	}
+}

pkg/plugin/source.go

@@ -166,7 +166,7 @@ func (s *SourcePluginSystem) Load(ctx context.Context) error {
 			Logger: hclog.New(&hclog.LoggerOptions{
 				Name:       "source",
 				Output:     os.Stdout,
-				Level:      hclog.Debug,
+				Level:      getLogLevel(),
 				JSONFormat: true,
 			}),
 		})

pkg/source/manager.go

@@ -91,7 +91,7 @@ func (m *Manager) Fetch(ctx context.Context) {
 				wg.Done()
 				return
 			}
-
+			logger.Debug("publishing instances", "instance count", len(instances))
 			err = m.publishInstances(instances)
 			if err != nil {
 				logger.Error("failed publishing instances", "error", err)