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 Limiter
  • func (l *Limiter) Pipe(in <-chan util.Param) <-chan util.Param
• type Piper
  • func NewDeduplicator(interval time.Duration, filter ...string) Piper
  • func NewDropper(filter ...string) Piper
  • func NewLimiter(interval time.Duration) 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 Limiter

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

Limiter allows filtering of channel data by given criteria

func (*Limiter) Pipe

func (l *Limiter) 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

func NewLimiter

func NewLimiter(interval time.Duration) Piper

NewLimiter creates limiter