event_merge

Documentation

Index

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

Types

type Merge

type Merge struct {
	Always bool `mapstructure:"always,omitempty" json:"always,omitempty"`
	Debug  bool `mapstructure:"debug,omitempty" json:"debug,omitempty"`
	// contains filtered or unexported fields
}

Merge merges a list of event messages into one or multiple messages based on some criteria

func (*Merge) Apply

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

func (*Merge) Init

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

func (*Merge) WithLogger

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

func (*Merge) WithTargets

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