Documentation ¶
Index ¶
- type Config
- type Factory
- func (f *Factory) CreateDefaultConfig() configmodels.Receiver
- func (f *Factory) CreateMetricsReceiver(logger *zap.Logger, cfg configmodels.Receiver, ...) (component.MetricsReceiver, error)
- func (f *Factory) CreateTraceReceiver(ctx context.Context, logger *zap.Logger, cfg configmodels.Receiver, ...) (component.TraceReceiver, error)
- func (f *Factory) CustomUnmarshaler() component.CustomUnmarshaler
- func (f *Factory) Type() string
- type Option
- type Receiver
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { receiver.SecureReceiverSettings `mapstructure:",squash"` // squash ensures fields are correctly decoded in embedded struct // Transport to use: one of tcp or unix, defaults to tcp Transport string `mapstructure:"transport"` // CorsOrigins are the allowed CORS origins for HTTP/JSON requests to grpc-gateway adapter // for the OTLP receiver. See github.com/rs/cors // An empty list means that CORS is not enabled at all. A wildcard (*) can be // used to match any origin or one or more characters of an origin. CorsOrigins []string `mapstructure:"cors_allowed_origins"` // Keepalive anchor for all the settings related to keepalive. Keepalive *serverParametersAndEnforcementPolicy `mapstructure:"keepalive,omitempty"` // MaxRecvMsgSizeMiB sets the maximum size (in MiB) of messages accepted by the server. MaxRecvMsgSizeMiB uint64 `mapstructure:"max_recv_msg_size_mib,omitempty"` // MaxConcurrentStreams sets the limit on the number of concurrent streams to each ServerTransport. // TODO(nilebox): This setting affecting HTTP/2 streams need to be tested MaxConcurrentStreams uint32 `mapstructure:"max_concurrent_streams,omitempty"` }
Config defines configuration for OTLP receiver.
type Factory ¶
type Factory struct { }
Factory is the Factory for receiver.
func (*Factory) CreateDefaultConfig ¶
func (f *Factory) CreateDefaultConfig() configmodels.Receiver
CreateDefaultConfig creates the default configuration for receiver.
func (*Factory) CreateMetricsReceiver ¶
func (f *Factory) CreateMetricsReceiver( logger *zap.Logger, cfg configmodels.Receiver, consumer consumer.MetricsConsumerOld, ) (component.MetricsReceiver, error)
CreateMetricsReceiver creates a metrics receiver based on provided config.
func (*Factory) CreateTraceReceiver ¶
func (f *Factory) CreateTraceReceiver( ctx context.Context, logger *zap.Logger, cfg configmodels.Receiver, nextConsumer consumer.TraceConsumerOld, ) (component.TraceReceiver, error)
CreateTraceReceiver creates a trace receiver based on provided config.
func (*Factory) CustomUnmarshaler ¶
func (f *Factory) CustomUnmarshaler() component.CustomUnmarshaler
CustomUnmarshaler returns nil because we don't need custom unmarshaling for this config.
type Option ¶
type Option interface {
// contains filtered or unexported methods
}
Option interface defines for configuration settings to be applied to receivers.
withReceiver applies the configuration to the given receiver.
func ToOTLPReceiverServerOption ¶
func ToOTLPReceiverServerOption(tlsCreds *receiver.TLSCredentials) (opt Option, ok bool, err error)
ToOTLPReceiverServerOption checks if the TLS credentials in the form of a certificate file and a key file. If they aren't, it will return otlpreceiver.WithNoopOption() and a nil error. Otherwise, it will try to retrieve gRPC transport credentials from the file combinations, and create a option, along with any errors encountered while retrieving the credentials.
func WithCorsOrigins ¶
WithCorsOrigins is an option to specify the allowed origins to enable writing HTTP/JSON requests to the grpc-gateway adapter using CORS.
func WithGRPCServerOptions ¶
func WithGRPCServerOptions(gsOpts ...grpc.ServerOption) Option
WithGRPCServerOptions allows one to specify the options for starting a gRPC server.
func WithNoopOption ¶
func WithNoopOption() Option
WithNoopOption returns an option that doesn't mutate the receiver.
type Receiver ¶
type Receiver struct {
// contains filtered or unexported fields
}
Receiver is the type that exposes Trace and Metrics reception.
func New ¶
func New( instanceName string, transport string, addr string, tc consumer.TraceConsumerOld, mc consumer.MetricsConsumerOld, opts ...Option, ) (*Receiver, error)
New just creates the OpenTelemetry receiver services. It is the caller's responsibility to invoke the respective Start*Reception methods as well as the various Stop*Reception methods to end it.