sinks

type NewSinkFunc ¶

type NewSinkFunc func(cfg interface{}) (Sink, error)

build sink func

type ReceiverConfig ¶

type ReceiverConfig struct {
	Name   string
	Config interface{}
}

type Sink ¶

type Sink interface {
	Send(ctx context.Context, ev *kube.EnhancedEvent) error
	Close()
}

Sink is the interface that the third-party providers should implement. It should just get the event and transform it depending on its configuration and submit it. Error handling for retries etc. should be handled inside for now.

func NewAlertmanagerSink(cfg interface{}) (Sink, error)