pipe

package
v0.0.0-...-4e778a2 Latest Latest
Warning

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

Go to latest
Published: Dec 2, 2024 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 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

Jump to

Keyboard shortcuts

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