processors

package
v0.20.0-alpha1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

Functions

This section is empty.

Types

type ClusterAggregator

type ClusterAggregator struct {
	MetricsToAggregate []string
}

func (*ClusterAggregator) Name

func (this *ClusterAggregator) Name() string

func (*ClusterAggregator) Process

func (this *ClusterAggregator) Process(batch *core.DataBatch) (*core.DataBatch, error)

type NamespaceAggregator

type NamespaceAggregator struct {
	MetricsToAggregate []string
}

func (*NamespaceAggregator) Name

func (this *NamespaceAggregator) Name() string

func (*NamespaceAggregator) Process

func (this *NamespaceAggregator) Process(batch *core.DataBatch) (*core.DataBatch, error)

type NamespaceBasedEnricher

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

func NewNamespaceBasedEnricher

func NewNamespaceBasedEnricher(url *url.URL) (*NamespaceBasedEnricher, error)

func (*NamespaceBasedEnricher) Name

func (this *NamespaceBasedEnricher) Name() string

func (*NamespaceBasedEnricher) Process

func (this *NamespaceBasedEnricher) Process(batch *core.DataBatch) (*core.DataBatch, error)

type NodeAggregator

type NodeAggregator struct {
	MetricsToAggregate []string
}

func (*NodeAggregator) Name

func (this *NodeAggregator) Name() string

func (*NodeAggregator) Process

func (this *NodeAggregator) Process(batch *core.DataBatch) (*core.DataBatch, error)

type PodAggregator

type PodAggregator struct {
}

func (*PodAggregator) Name

func (this *PodAggregator) Name() string

func (*PodAggregator) Process

func (this *PodAggregator) Process(batch *core.DataBatch) (*core.DataBatch, error)

type PodBasedEnricher

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

func NewPodBasedEnricher

func NewPodBasedEnricher(url *url.URL) (*PodBasedEnricher, error)

func (*PodBasedEnricher) Name

func (this *PodBasedEnricher) Name() string

func (*PodBasedEnricher) Process

func (this *PodBasedEnricher) Process(batch *core.DataBatch) (*core.DataBatch, error)

Jump to

Keyboard shortcuts

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