sink

package
v0.26.0 Latest Latest
Warning

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

Go to latest
Published: Dec 28, 2021 License: Apache-2.0 Imports: 3 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateMetricsSink

func CreateMetricsSink(sinkType string, config map[string]interface{}) (types.MetricsSink, error)

CreateMetricsSink creates a MetricsSink according to sinkType

func IsExclusionKeys

func IsExclusionKeys(key string) bool

func IsExclusionLabels

func IsExclusionLabels(labels []string) bool

If one of the input labels matched the filter's labels, returns true

func RegisterSink

func RegisterSink(sinkType string, creator MetricsSinkCreator)

RegisterSink registers the sinkType as MetricsSinkCreator

func SetFilterKeys

func SetFilterKeys(keys []string)

func SetFilterLabels

func SetFilterLabels(labels []string)

deep copy

Types

type FlushFilter

type FlushFilter struct {
	Labels []string
	Keys   []string
	// contains filtered or unexported fields
}

type MetricsSinkCreator

type MetricsSinkCreator func(config map[string]interface{}) (types.MetricsSink, error)

MetricsSinkCreator creates a MetricsSink according to config

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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