pushreceiver

Documentation

Index

• Constants
• func NewFactory() component.ReceiverFactory
• type Factory
  • func (f *Factory) CreateDefaultConfig() config.Receiver
  • func (f *Factory) CreateLogsReceiver(ctx context.Context, set component.ReceiverCreateSettings, cfg config.Receiver, ...) (component.LogsReceiver, error)
  • func (f *Factory) CreateMetricsReceiver(ctx context.Context, set component.ReceiverCreateSettings, cfg config.Receiver, ...) (component.MetricsReceiver, error)
  • func (f *Factory) CreateTracesReceiver(_ context.Context, _ component.ReceiverCreateSettings, _ config.Receiver, ...) (component.TracesReceiver, error)
  • func (f *Factory) LogsReceiverStability() component.StabilityLevel
  • func (f *Factory) MetricsReceiverStability() component.StabilityLevel
  • func (f *Factory) TracesReceiverStability() component.StabilityLevel
  • func (f Factory) Type() config.Type

Constants

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

Functions

func NewFactory

func NewFactory() component.ReceiverFactory

NewFactory creates a new push receiver factory.

Types

type Factory

type Factory struct {
	component.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() config.Receiver

CreateDefaultConfig creates a default push receiver config.

func (*Factory) CreateLogsReceiver

func (f *Factory) CreateLogsReceiver(ctx context.Context, set component.ReceiverCreateSettings,
	cfg config.Receiver, nextConsumer consumer.Logs) (component.LogsReceiver, error)

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

func (*Factory) CreateMetricsReceiver

func (f *Factory) CreateMetricsReceiver(ctx context.Context, set component.ReceiverCreateSettings,
	cfg config.Receiver, nextConsumer consumer.Metrics) (component.MetricsReceiver, error)

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

func (*Factory) CreateTracesReceiver

func (f *Factory) CreateTracesReceiver(
	_ context.Context,
	_ component.ReceiverCreateSettings,
	_ config.Receiver,
	c consumer.Traces,
) (component.TracesReceiver, 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() config.Type

Type returns the receiver type that PushReceiverFactory produces