mockawsxrayreceiver

Documentation

Index

• func NewFactory() receiver.Factory
• func ToTraces(rawSeg []byte) (ptrace.Traces, error)
• type Config
• type MockAwsXrayReceiver
  • func New(nextConsumer consumer.Traces, params receiver.CreateSettings, config *Config) (*MockAwsXrayReceiver, error)
  • func (ar *MockAwsXrayReceiver) HTTPHandlerFunc(rw http.ResponseWriter, req *http.Request)
  • func (ar *MockAwsXrayReceiver) Shutdown(context.Context) error
  • func (ar *MockAwsXrayReceiver) Start(_ context.Context, host component.Host) error

Functions

func NewFactory

func NewFactory() receiver.Factory

NewFactory creates a factory for SAPM receiver.

func ToTraces

func ToTraces(rawSeg []byte) (ptrace.Traces, error)

Types

type Config

type Config struct {
	config.ReceiverSettings `mapstructure:",squash"` // squash ensures fields are correctly decoded in embedded struct

	// The target endpoint.
	Endpoint string `mapstructure:"endpoint"`

	// Configures the receiver to use TLS.
	// The default value is nil, which will cause the receiver to not use TLS.
	TLSCredentials *configtls.TLSSetting `mapstructure:"tls, omitempty"`
}

Config defines configuration for xray receiver.

type MockAwsXrayReceiver

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

MockAwsXrayReceiver type is used to handle spans received in the AWS data format.

func New

func New(
	nextConsumer consumer.Traces,
	params receiver.CreateSettings,
	config *Config) (*MockAwsXrayReceiver, error)

New creates a new awsxrayreceiver.MockAwsXrayReceiver reference.

func (*MockAwsXrayReceiver) HTTPHandlerFunc

func (ar *MockAwsXrayReceiver) HTTPHandlerFunc(rw http.ResponseWriter, req *http.Request)

HTTPHandlerFunc returns an http.HandlerFunc that handles awsXray requests

func (*MockAwsXrayReceiver) Shutdown

func (ar *MockAwsXrayReceiver) Shutdown(context.Context) error

Shutdown tells the receiver that should stop reception, giving it a chance to perform any necessary clean-up and shutting down its HTTP server.

func (*MockAwsXrayReceiver) Start

func (ar *MockAwsXrayReceiver) Start(_ context.Context, host component.Host) error

Start spins up the receiver's HTTP server and makes the receiver start its processing.