receiver

package
v0.39.0-rc.0 Latest Latest
Warning

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

Go to latest
Published: Jan 5, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

Package receiver utilities to create a Flow component from OpenTelemetry Collector receivers.

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 receiver
	// configuration.
	Convert() (otelcomponent.Config, error)

	// Extensions returns the set of extensions that the configured component is
	// allowed to use.
	Extensions() map[otelcomponent.ID]extension.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

	// DebugMetricsConfig returns the configuration for debug metrics
	DebugMetricsConfig() otelcol.DebugMetricsArguments
}

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

type Receiver

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

Receiver is a Flow component shim which manages an OpenTelemetry Collector receiver component.

func New

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

If the registered Flow component registers exported fields, it is the responsibility of the caller to export values when needed; the Receiver component never exports any values.

func (*Receiver) CurrentHealth

func (r *Receiver) CurrentHealth() component.Health

CurrentHealth implements component.HealthComponent.

func (*Receiver) Run

func (r *Receiver) Run(ctx context.Context) error

Run starts the Receiver component.

func (*Receiver) Update

func (r *Receiver) Update(args component.Arguments) error

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

Directories

Path Synopsis
Package jaeger provides an otelcol.receiver.jaeger component.
Package jaeger provides an otelcol.receiver.jaeger component.
Package kafka provides an otelcol.receiver.kafka component.
Package kafka provides an otelcol.receiver.kafka component.
Package loki provides an otelcol.receiver.loki component.
Package loki provides an otelcol.receiver.loki component.
Package opencensus provides an otelcol.receiver.opencensus component.
Package opencensus provides an otelcol.receiver.opencensus component.
Package otlp provides an otelcol.receiver.otlp component.
Package otlp provides an otelcol.receiver.otlp component.
Package prometheus provides an otelcol.receiver.prometheus component.
Package prometheus provides an otelcol.receiver.prometheus component.
internal
Package internal is a near copy of https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/v0.87.0/receiver/prometheusreceiver/internal A copy was made because the upstream package is internal.
Package internal is a near copy of https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/v0.87.0/receiver/prometheusreceiver/internal A copy was made because the upstream package is internal.
Package vcenter provides an otelcol.receiver.vcenter component.
Package vcenter provides an otelcol.receiver.vcenter component.
Package zipkin provides an otelcol.receiver.zipkin component.
Package zipkin provides an otelcol.receiver.zipkin component.

Jump to

Keyboard shortcuts

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