unpoller/pkg/otelunifi/logger.go

package otelunifi

import (
	"fmt"
	"time"

	"github.com/unpoller/unpoller/pkg/webserver"
)

// Logf logs an informational message.
func (u *OtelOutput) Logf(msg string, v ...any) {
	webserver.NewOutputEvent(PluginName, PluginName, &webserver.Event{
		Ts:   time.Now(),
		Msg:  fmt.Sprintf(msg, v...),
		Tags: map[string]string{"type": "info"},
	})

	if u.Collector != nil {
		u.Collector.Logf(msg, v...)
	}
}

// LogErrorf logs an error message.
func (u *OtelOutput) LogErrorf(msg string, v ...any) {
	webserver.NewOutputEvent(PluginName, PluginName, &webserver.Event{
		Ts:   time.Now(),
		Msg:  fmt.Sprintf(msg, v...),
		Tags: map[string]string{"type": "error"},
	})

	if u.Collector != nil {
		u.Collector.LogErrorf(msg, v...)
	}
}

// LogDebugf logs a debug message.
func (u *OtelOutput) LogDebugf(msg string, v ...any) {
	webserver.NewOutputEvent(PluginName, PluginName, &webserver.Event{
		Ts:   time.Now(),
		Msg:  fmt.Sprintf(msg, v...),
		Tags: map[string]string{"type": "debug"},
	})

	if u.Collector != nil {
		u.Collector.LogDebugf(msg, v...)
	}
}