processor

package
v0.0.0-...-0da8dc2 Latest Latest
Warning

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

Go to latest
Published: Jan 14, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Queue            workqueue.RateLimitingInterface
	PruneFields      map[string][]string
	PruneFieldsLock  sync.RWMutex
	FilterEvents     map[string][]string
	FilterEventsLock sync.RWMutex
)

Functions

func SetFilterEvents

func SetFilterEvents(resources []config.Resource)

SetFilterEvents accepts a config.Resource that will be used to determine the events that should be filtered out.

func SetPruneFields

func SetPruneFields(resources []config.Resource)

SetPruneFields accepts a config.Resource that will be used to determine the fields that should be pruned accordingly.

func StartProcessor

func StartProcessor(resources []config.Resource)

StartProcessor starts the go routine responsible for checking to see if there are events from informers that should make their way to the emit queue.

Types

This section is empty.

Jump to

Keyboard shortcuts

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