extensions

Documentation

Index

• func NewLFUMessageCache(lub int) messageCache[alertingv1.OpniSeverity, *alertingv1.MessageInstance]
• func ParseIncomingWebhookMessage(req *http.Request) (config.WebhookMessage, error)
• func StartOpniEmbeddedServer(ctx context.Context, opniAddr string) *http.Server
• type EmbeddedServer
  • func NewEmbeddedServer(lg *zap.SugaredLogger, lub int) *EmbeddedServer
• type MessageMetadata

Functions

func NewLFUMessageCache

func NewLFUMessageCache(lub int) messageCache[alertingv1.OpniSeverity, *alertingv1.MessageInstance]

func ParseIncomingWebhookMessage

func ParseIncomingWebhookMessage(req *http.Request) (config.WebhookMessage, error)

ParseIncomingWebhookMessage return non-pointer for performance reasons

func StartOpniEmbeddedServer

func StartOpniEmbeddedServer(ctx context.Context, opniAddr string) *http.Server

Types

type EmbeddedServer

type EmbeddedServer struct {
	// contains filtered or unexported fields
}

Embedded Server handles all incoming webhook requests from the AlertManager

func NewEmbeddedServer

func NewEmbeddedServer(
	lg *zap.SugaredLogger,
	lub int,
) *EmbeddedServer

type MessageMetadata

type MessageMetadata struct {
	IsAlarm           bool
	Uuid              string
	GroupDedupeKey    string
	Fingerprint       string
	SourceFingerprint string
	Severity          int32
}