gotel

type CustomAttributesFunc func(r *http.Request) []attribute.KeyValue

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

type NewWrapResponseWriterFunc func(w http.ResponseWriter, protoMajor int) WrapResponseWriter

type OTELLogsExporterType string

type OTELMetricsExporterType string

type OTLPCompressionType string

type OTLPConfig struct {
	// OpenTelemetry service name.
	ServiceName string `json:"serviceName,omitempty" yaml:"serviceName,omitempty" env:"OTEL_SERVICE_NAME" help:"OpenTelemetry service name."`
	// OTLP receiver endpoint that is set as default for all types.
	OtlpEndpoint string `` /* 161-byte string literal not displayed */
	// OTLP receiver endpoint for traces exporter.
	OtlpTracesEndpoint string `` /* 154-byte string literal not displayed */
	// OTLP receiver endpoint for metrics exporter.
	OtlpMetricsEndpoint string `` /* 158-byte string literal not displayed */
	// OTLP receiver endpoint for logs exporter.
	OtlpLogsEndpoint string `` /* 146-byte string literal not displayed */
	// Disable TLS for OpenTelemetry exporters.
	OtlpInsecure *bool `` /* 141-byte string literal not displayed */
	// Disable TLS for OpenTelemetry traces exporter.
	OtlpTracesInsecure *bool `` /* 166-byte string literal not displayed */
	// Disable TLS for OpenTelemetry metrics exporter.
	OtlpMetricsInsecure *bool `` /* 170-byte string literal not displayed */
	// Disable TLS for OpenTelemetry logs exporter.
	OtlpLogsInsecure *bool `` /* 158-byte string literal not displayed */
	// OTLP receiver protocol for all exporters. Default is grpc.
	OtlpProtocol OTLPProtocol `` /* 241-byte string literal not displayed */
	// OTLP receiver protocol for traces.
	OtlpTracesProtocol OTLPProtocol `` /* 234-byte string literal not displayed */
	// OTLP receiver protocol for metrics.
	OtlpMetricsProtocol OTLPProtocol `` /* 238-byte string literal not displayed */
	// OTLP receiver protocol for logs.
	OtlpLogsProtocol OTLPProtocol `` /* 226-byte string literal not displayed */
	// Enable compression for OTLP exporters. Accept: none, gzip
	OtlpCompression OTLPCompressionType `` /* 232-byte string literal not displayed */
	// Enable compression for OTLP traces exporter. Accept: none, gzip
	OtlpTracesCompression OTLPCompressionType `` /* 254-byte string literal not displayed */
	// Enable compression for OTLP metrics exporter. Accept: none, gzip
	OtlpMetricsCompression OTLPCompressionType `` /* 258-byte string literal not displayed */
	// Enable compression for OTLP logs exporter. Accept: none, gzip
	OtlpLogsCompression OTLPCompressionType `` /* 246-byte string literal not displayed */
	// Metrics export type. Accept: none, otlp, prometheus
	MetricsExporter OTELMetricsExporterType `` /* 244-byte string literal not displayed */
	// Logs export type. Accept: none, otlp
	LogsExporter OTELLogsExporterType `` /* 193-byte string literal not displayed */
	// Prometheus port for the Prometheus HTTP server. Use /metrics endpoint of the connector server if empty.
	PrometheusPort *uint `` /* 249-byte string literal not displayed */
	// Disable internal Go and process metrics (prometheus exporter only).
	DisableGoMetrics *bool `json:"disableGoMetrics,omitempty" yaml:"disableGoMetrics,omitempty" help:"Disable internal Go and process metrics"`
}

type OTLPProtocol string

type OTelExporters struct {
	Tracer   *Tracer
	Meter    metricapi.Meter
	Logger   *slog.Logger
	Shutdown func(context.Context) error
}

type Tracer struct {
	traceapi.Tracer
}

type TracingMiddlewareOption func(*tracingMiddlewareOptions)

type WrapResponseWriter interface {
	http.ResponseWriter
	// Status returns the HTTP status of the request, or 0 if one has not
	// yet been sent.
	Status() int
	// BytesWritten returns the total number of bytes sent to the client.
	BytesWritten() int
	// Tee causes the response body to be written to the given io.Writer in
	// addition to proxying the writes through. Only one io.Writer can be
	// tee'd to at once: setting a second one will overwrite the first.
	// Writes will be sent to the proxy before being written to this
	// io.Writer. It is illegal for the tee'd writer to be modified
	// concurrently with writes.
	Tee(w io.Writer)
	// Unwrap returns the original proxied target.
	Unwrap() http.ResponseWriter
	// Discard causes all writes to the original ResponseWriter be discarded,
	// instead writing only to the tee'd writer if it's set.
	// The caller is responsible for calling WriteHeader and Write on the
	// original ResponseWriter once the processing is done.
	Discard()
}