processor

package
v0.36.0-rc.3 Latest Latest
Warning

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

Go to latest
Published: Aug 28, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package processor exposes utilities to create a Flow component from OpenTelemetry Collector processors.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Arguments

type Arguments interface {
	component.Arguments

	// Convert converts the Arguments into an OpenTelemetry Collector processor
	// configuration.
	Convert() (otelcomponent.Config, error)

	// Extensions returns the set of extensions that the configured component is
	// allowed to use.
	Extensions() map[otelcomponent.ID]otelextension.Extension

	// Exporters returns the set of exporters that are exposed to the configured
	// component.
	Exporters() map[otelcomponent.DataType]map[otelcomponent.ID]otelcomponent.Component

	// NextConsumers returns the set of consumers to send data to.
	NextConsumers() *otelcol.ConsumerArguments
}

Arguments is an extension of component.Arguments which contains necessary settings for OpenTelemetry Collector processors.

type Processor

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

Processor is a Flow component shim which manages an OpenTelemetry Collector processor component.

func New

New creates a new Flow component which encapsulates an OpenTelemetry Collector processor. args must hold a value of the argument type registered with the Flow component.

The registered component must be registered to export the otelcol.ConsumerExports type, otherwise New will panic.

func (*Processor) CurrentHealth

func (p *Processor) CurrentHealth() component.Health

CurrentHealth implements component.HealthComponent.

func (*Processor) Run

func (p *Processor) Run(ctx context.Context) error

Run starts the Processor component.

func (*Processor) Update

func (p *Processor) Update(args component.Arguments) error

Update implements component.Component. It will convert the Arguments into configuration for OpenTelemetry Collector processor configuration and manage the underlying OpenTelemetry Collector processor.

Directories

Path Synopsis
Package attributes provides an otelcol.processor.attributes component.
Package attributes provides an otelcol.processor.attributes component.
Package batch provides an otelcol.processor.batch component.
Package batch provides an otelcol.processor.batch component.
Package discovery provides an otelcol.processor.discovery component.
Package discovery provides an otelcol.processor.discovery component.
Package memorylimiter provides an otelcol.processor.memory_limiter component.
Package memorylimiter provides an otelcol.processor.memory_limiter component.
Package span provides an otelcol.processor.span component.
Package span provides an otelcol.processor.span component.
Package tail_sampling provides an otelcol.processor.tail_sampling component.
Package tail_sampling provides an otelcol.processor.tail_sampling component.

Jump to

Keyboard shortcuts

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