mirror of
https://github.com/hanzoai/metrics.git
synced 2026-10-30 20:03:39 +00:00
45 lines
1.0 KiB
Go
45 lines
1.0 KiB
Go
package notifier
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/lib/prompb"
|
|
)
|
|
|
|
// blackHoleNotifier is a Notifier stub, used when no notifications need
|
|
// to be sent.
|
|
type blackHoleNotifier struct {
|
|
addr string
|
|
metrics *notifierMetrics
|
|
}
|
|
|
|
// Send will send no notifications, but increase the metric.
|
|
func (bh *blackHoleNotifier) Send(_ context.Context, alerts []Alert, _ [][]prompb.Label, _ map[string]string) error { //nolint:revive
|
|
bh.metrics.alertsSent.Add(len(alerts))
|
|
return nil
|
|
}
|
|
|
|
// Addr of black hole notifier
|
|
func (bh blackHoleNotifier) Addr() string {
|
|
return bh.addr
|
|
}
|
|
|
|
// Close unregister the metrics
|
|
func (bh *blackHoleNotifier) Close() {
|
|
bh.metrics.close()
|
|
}
|
|
|
|
// LastError return last notifier's error
|
|
func (bh *blackHoleNotifier) LastError() string {
|
|
return ""
|
|
}
|
|
|
|
// newBlackHoleNotifier creates a new blackHoleNotifier
|
|
func newBlackHoleNotifier() *blackHoleNotifier {
|
|
address := "blackhole"
|
|
return &blackHoleNotifier{
|
|
addr: address,
|
|
metrics: newNotifierMetrics(address),
|
|
}
|
|
}
|