pushreceiver

Documentation

Index

• Constants
• func NewFactory() otelreceiver.Factory
• type Factory
  • func (f *Factory) CreateDefaultConfig() component.Config
  • func (f *Factory) CreateLogsReceiver(ctx context.Context, set otelreceiver.Settings, cfg component.Config, ...) (otelreceiver.Logs, error)
  • func (f *Factory) CreateMetricsReceiver(ctx context.Context, set otelreceiver.Settings, cfg component.Config, ...) (otelreceiver.Metrics, error)
  • func (f *Factory) CreateTracesReceiver(_ context.Context, _ otelreceiver.Settings, _ component.Config, ...) (otelreceiver.Traces, error)
  • func (f *Factory) LogsReceiverStability() component.StabilityLevel
  • func (f *Factory) MetricsReceiverStability() component.StabilityLevel
  • func (f *Factory) TracesReceiverStability() component.StabilityLevel
  • func (f Factory) Type() component.Type

Constants

const (
	//TypeStr for push receiver.
	TypeStr = "push_receiver"
)

Functions

func NewFactory

func NewFactory() otelreceiver.Factory

NewFactory creates a new push receiver factory.

Types

type Factory

type Factory struct {
	otelreceiver.Factory
	Consumer consumer.Traces
}

Factory is a factory that sneakily exposes a Traces consumer for use within the agent.

func (*Factory) CreateDefaultConfig

func (f *Factory) CreateDefaultConfig() component.Config

CreateDefaultConfig creates a default push receiver config.

func (*Factory) CreateLogsReceiver

func (f *Factory) CreateLogsReceiver(ctx context.Context, set otelreceiver.Settings,
	cfg component.Config, nextConsumer consumer.Logs) (otelreceiver.Logs, error)

CreateLogsReceiver returns an error because logs are not supported by push receiver.

func (*Factory) CreateMetricsReceiver

func (f *Factory) CreateMetricsReceiver(ctx context.Context, set otelreceiver.Settings,
	cfg component.Config, nextConsumer consumer.Metrics) (otelreceiver.Metrics, error)

CreateMetricsReceiver returns an error because metrics are not supported by push receiver.

func (*Factory) CreateTracesReceiver

func (f *Factory) CreateTracesReceiver(
	_ context.Context,
	_ otelreceiver.Settings,
	_ component.Config,
	c consumer.Traces,
) (otelreceiver.Traces, error)

CreateTracesReceiver creates a stub receiver while also sneakily keeping a reference to the provided Traces consumer.

func (*Factory) LogsReceiverStability

func (f *Factory) LogsReceiverStability() component.StabilityLevel

LogsReceiverStability implements component.ReceiverFactory.

func (*Factory) MetricsReceiverStability

func (f *Factory) MetricsReceiverStability() component.StabilityLevel

MetricsReceiverStability implements component.ReceiverFactory.

func (*Factory) TracesReceiverStability

func (f *Factory) TracesReceiverStability() component.StabilityLevel

TracesReceiverStability implements component.ReceiverFactory.

func (Factory) Type

func (f Factory) Type() component.Type

Type returns the receiver type that PushReceiverFactory produces