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 ¶
func New(opts component.Options, f otelreceiver.Factory, args Arguments) (*Receiver, error)
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.
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. |
Package zipkin provides an otelcol.receiver.zipkin component.
|
Package zipkin provides an otelcol.receiver.zipkin component. |