output

package
v0.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 1, 2022 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CollectorOutput

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

func NewCollectorOutput

func NewCollectorOutput(wg *sync.WaitGroup, options CollectorOutputOptions, templateOptions render.TextTemplateOptions, observability common.Observability) *CollectorOutput

func (*CollectorOutput) Send

func (c *CollectorOutput) Send(event *common.Event)

type CollectorOutputOptions

type CollectorOutputOptions struct {
	Address string
	Message string
}

type GrafanaOutput added in v0.1.0

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

func NewGrafanaOutput added in v0.1.0

func NewGrafanaOutput(wg *sync.WaitGroup,
	options GrafanaOutputOptions,
	templateOptions render.TextTemplateOptions,
	observability common.Observability,
	grafanaEventer *sreProvider.GrafanaEventer) *GrafanaOutput

func (*GrafanaOutput) Send added in v0.1.0

func (g *GrafanaOutput) Send(event *common.Event)

type GrafanaOutputOptions added in v0.1.0

type GrafanaOutputOptions struct {
	Message            string
	AttributesSelector string
}

type KafkaOutput

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

func NewKafkaOutput

func NewKafkaOutput(wg *sync.WaitGroup, options KafkaOutputOptions, templateOptions render.TextTemplateOptions, observability common.Observability) *KafkaOutput

func (*KafkaOutput) Send

func (k *KafkaOutput) Send(event *common.Event)

type KafkaOutputOptions

type KafkaOutputOptions struct {
	ClientID           string
	Message            string
	Brokers            string
	Topic              string
	FlushFrequency     int
	FlushMaxMessages   int
	NetMaxOpenRequests int
	NetDialTimeout     int
	NetReadTimeout     int
	NetWriteTimeout    int
}

type NewRelicOutput added in v0.1.0

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

func NewNewRelicOutput added in v0.1.0

func NewNewRelicOutput(wg *sync.WaitGroup,
	options NewRelicOutputOptions,
	templateOptions render.TextTemplateOptions,
	observability common.Observability,
	newrelicEventer *sreProvider.NewRelicEventer) *NewRelicOutput

func (*NewRelicOutput) Send added in v0.1.0

func (r *NewRelicOutput) Send(event *common.Event)

type NewRelicOutputOptions added in v0.1.0

type NewRelicOutputOptions struct {
	Message            string
	AttributesSelector string
}

type SlackOutput

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

func NewSlackOutput

func NewSlackOutput(wg *sync.WaitGroup,
	options SlackOutputOptions,
	templateOptions render.TextTemplateOptions,
	grafanaRenderOptions render.GrafanaRenderOptions,
	observability common.Observability) *SlackOutput

func (*SlackOutput) Send

func (s *SlackOutput) Send(event *common.Event)

type SlackOutputOptions

type SlackOutputOptions struct {
	Message         string
	URLSelector     string
	URL             string
	Timeout         int
	AlertExpression string
}

type TelegramOutput

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

func NewTelegramOutput

func NewTelegramOutput(wg *sync.WaitGroup,
	options TelegramOutputOptions,
	templateOptions render.TextTemplateOptions,
	grafanaRenderOptions render.GrafanaRenderOptions, observability common.Observability) *TelegramOutput

func (*TelegramOutput) Send

func (t *TelegramOutput) Send(event *common.Event)

type TelegramOutputOptions

type TelegramOutputOptions struct {
	Message             string
	URLSelector         string
	URL                 string
	Timeout             int
	AlertExpression     string
	DisableNotification string
}

type WorkchatOutput

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

func NewWorkchatOutput

func NewWorkchatOutput(wg *sync.WaitGroup,
	options WorkchatOutputOptions,
	templateOptions render.TextTemplateOptions,
	grafanaRenderOptions render.GrafanaRenderOptions,
	observability common.Observability) *WorkchatOutput

func (*WorkchatOutput) Send

func (w *WorkchatOutput) Send(event *common.Event)

type WorkchatOutputOptions

type WorkchatOutputOptions struct {
	Message          string
	URLSelector      string
	URL              string
	Timeout          int
	AlertExpression  string
	NotificationType string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL