neosyncotel

Documentation

Index

• func GetBenthosMetricTemporalityOption() otlpmetricgrpc.Option
• func NewDefaultPropagator() propagation.TextMapPropagator
• func NewMeterProvider(ctx context.Context, config *MeterProviderConfig) (*metricsdk.MeterProvider, error)
• func NewTraceProvider(ctx context.Context, config *TraceProviderConfig) (*tracesdk.TracerProvider, error)
• func SetupOtelSdk(config *SetupConfig) func(context.Context) error
• func WithDefaultDeltaTemporalitySelector() otlpmetricgrpc.Option
• type MeterExporterOpts
• type MeterProvider
• type MeterProviderConfig
• type OtelEnvConfig
  • func GetOtelConfigFromViperEnv() OtelEnvConfig
• type SetupConfig
• type TraceExporterOpts
• type TraceProviderConfig
• type TracerProvider

Functions

func GetBenthosMetricTemporalityOption

func GetBenthosMetricTemporalityOption() otlpmetricgrpc.Option

This will be used to test sending benthos metrics with cumulative temporality instead of delta for better prometheus compatibility

func NewDefaultPropagator

func NewDefaultPropagator() propagation.TextMapPropagator

func NewMeterProvider

func NewMeterProvider(ctx context.Context, config *MeterProviderConfig) (*metricsdk.MeterProvider, error)

func NewTraceProvider

func NewTraceProvider(ctx context.Context, config *TraceProviderConfig) (*tracesdk.TracerProvider, error)

func SetupOtelSdk

func SetupOtelSdk(config *SetupConfig) func(context.Context) error

func WithDefaultDeltaTemporalitySelector

func WithDefaultDeltaTemporalitySelector() otlpmetricgrpc.Option

Types

type MeterExporterOpts

type MeterExporterOpts struct {
	Otlp    []otlpmetricgrpc.Option
	Console []stdoutmetric.Option
}

type MeterProvider

type MeterProvider interface {
	metric.MeterProvider

	Shutdown(context.Context) error
}

type MeterProviderConfig

type MeterProviderConfig struct {
	Exporter   string
	Opts       MeterExporterOpts
	AppVersion string
}

type OtelEnvConfig

type OtelEnvConfig struct {
	IsEnabled      bool
	ServiceVersion string

	TraceExporter string
	MeterExporter string
}

func GetOtelConfigFromViperEnv

func GetOtelConfigFromViperEnv() OtelEnvConfig

type SetupConfig

type SetupConfig struct {
	TraceProviders []TracerProvider
	MeterProviders []MeterProvider
	// If provided, configures the global text map propagator
	TextMapPropagator propagation.TextMapPropagator
	// Configures the global otel logger
	Logger logr.Logger
}

type TraceExporterOpts

type TraceExporterOpts struct {
	Otlp    []otlptracegrpc.Option
	Console []stdouttrace.Option
}

type TraceProviderConfig

type TraceProviderConfig struct {
	Exporter string
	Opts     TraceExporterOpts
}

type TracerProvider

type TracerProvider interface {
	trace.TracerProvider

	Shutdown(context.Context) error
}