pipe

Documentation

Index

• type Deduplicator
  • func (l *Deduplicator) Pipe(in <-chan util.Param) <-chan util.Param
• type Dropper
  • func (l *Dropper) Pipe(in <-chan util.Param) <-chan util.Param
• type Piper
  • func NewDeduplicator(interval time.Duration, filter ...string) Piper
  • func NewDropper(filter ...string) Piper

Types

type Deduplicator

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

Deduplicator allows filtering of channel data by given criteria

func (*Deduplicator) Pipe

func (l *Deduplicator) Pipe(in <-chan util.Param) <-chan util.Param

Pipe creates a new filtered output channel for given input channel

type Dropper

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

Dropper allows filtering of channel data by given criteria

func (*Dropper) Pipe

func (l *Dropper) Pipe(in <-chan util.Param) <-chan util.Param

Pipe creates a new filtered output channel for given input channel

type Piper

type Piper interface {
	Pipe(in <-chan util.Param) <-chan util.Param
}

Piper is the interface that data flow plugins must implement

func NewDeduplicator

func NewDeduplicator(interval time.Duration, filter ...string) Piper

NewDeduplicator creates Deduplicator

func NewDropper

func NewDropper(filter ...string) Piper

NewDropper creates Dropper