event_trigger

Documentation

Index

• type Trigger
  • func (p *Trigger) Apply(es ...*formatters.EventMsg) []*formatters.EventMsg
  • func (p *Trigger) Init(cfg interface{}, opts ...formatters.Option) error
  • func (p *Trigger) String() string
  • func (p *Trigger) WithLogger(l *log.Logger)
  • func (p *Trigger) WithTargets(tcs map[string]interface{})

Types

type Trigger

type Trigger struct {
	Condition      string                 `mapstructure:"condition,omitempty"`
	MinOccurrences int                    `mapstructure:"min-occurrences,omitempty"`
	MaxOccurrences int                    `mapstructure:"max-occurrences,omitempty"`
	Window         time.Duration          `mapstructure:"window,omitempty"`
	Action         map[string]interface{} `mapstructure:"action,omitempty"`
	Debug          bool                   `mapstructure:"debug,omitempty"`
	// contains filtered or unexported fields
}

Trigger triggers an action when certain conditions are met

func (*Trigger) Apply

func (p *Trigger) Apply(es ...*formatters.EventMsg) []*formatters.EventMsg

func (*Trigger) Init

func (p *Trigger) Init(cfg interface{}, opts ...formatters.Option) error

func (*Trigger) String

func (p *Trigger) String() string

func (*Trigger) WithLogger

func (p *Trigger) WithLogger(l *log.Logger)

func (*Trigger) WithTargets

func (p *Trigger) WithTargets(tcs map[string]interface{})