pipe

package
v0.0.0-...-175a4df Latest Latest
Warning

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

Go to latest
Published: Oct 27, 2023 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

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