type Compressionint

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

funcInstallNewPipeline¶added inv0.20.0

func InstallNewPipeline(ctxcontext.Context, driverProtocolDriver, exporterOpts ...ExporterOption) (*Exporter,*sdktrace.TracerProvider, *basic.Controller,error)

InstallNewPipeline instantiates a NewExportPipeline with therecommended configuration and registers it globally.

funcNewExportPipeline¶added inv0.20.0

func NewExportPipeline(ctxcontext.Context, driverProtocolDriver, exporterOpts ...ExporterOption) (*Exporter,*sdktrace.TracerProvider, *basic.Controller,error)

NewExportPipeline sets up a complete export pipelinewith the recommended TracerProvider setup.

funcNewExporter¶

func NewExporter(ctxcontext.Context, driverProtocolDriver, opts ...ExporterOption) (*Exporter,error)

NewExporter constructs a new Exporter and starts it.

package mainimport ("context""log""go.opentelemetry.io/otel/exporters/otlp""go.opentelemetry.io/otel""go.opentelemetry.io/otel/exporters/otlp/otlpgrpc"sdktrace "go.opentelemetry.io/otel/sdk/trace")func main() {ctx := context.Background()// Set different endpoints for the metrics and traces collectorsmetricsDriver := otlpgrpc.NewDriver(// Configure metrics driver here)tracesDriver := otlpgrpc.NewDriver(// Configure traces driver here)config := otlp.SplitConfig{ForMetrics: metricsDriver,ForTraces:  tracesDriver,}driver := otlp.NewSplitDriver(config)exporter, err := otlp.NewExporter(ctx, driver) // Configure as needed.if err != nil {log.Fatalf("failed to create exporter: %v", err)}defer func() {err := exporter.Shutdown(ctx)if err != nil {log.Fatalf("failed to stop exporter: %v", err)}}()tracerProvider := sdktrace.NewTracerProvider(sdktrace.WithBatcher(exporter))otel.SetTracerProvider(tracerProvider)}

funcNewUnstartedExporter¶

func NewUnstartedExporter(driverProtocolDriver, opts ...ExporterOption) *Exporter

NewUnstartedExporter constructs a new Exporter and does not start it.

func (*Exporter)Export¶

func (e *Exporter) Export(parentcontext.Context, cpsmetricsdk.CheckpointSet)error

Export transforms and batches metric Records into OTLP Metrics andtransmits them to the configured collector.

func (*Exporter)ExportKindFor¶added inv0.7.0

func (e *Exporter) ExportKindFor(desc *metric.Descriptor, kindaggregation.Kind)metricsdk.ExportKind

ExportKindFor reports back to the OpenTelemetry SDK sending this Exportermetric telemetry that it needs to be provided in a configured format.

func (*Exporter)ExportSpans¶

func (e *Exporter) ExportSpans(ctxcontext.Context, ss []*tracesdk.SpanSnapshot)error

ExportSpans transforms and batches trace SpanSnapshots into OTLP Trace andtransmits them to the configured collector.

func (*Exporter)Shutdown¶added inv0.12.0

func (e *Exporter) Shutdown(ctxcontext.Context)error

Shutdown closes all connections and releases resources currently being usedby the exporter. If the exporter is not started this does nothing. A shutdown exporter can't be started again. Shutting down an already shut downexporter does nothing.

func (*Exporter)Start¶

func (e *Exporter) Start(ctxcontext.Context)error

Start establishes connections to the OpenTelemetry collector. Starting analready started exporter returns an error.

type ExporterOption func(*config)

funcWithMetricExportKindSelector¶added inv0.14.0

func WithMetricExportKindSelector(selectormetricsdk.ExportKindSelector)ExporterOption

WithMetricExportKindSelector defines the ExportKindSelector usedfor selecting AggregationTemporality (i.e., Cumulative vs. Deltaaggregation). If not specified otherwise, exporter will use acumulative export kind selector.

type Marshalerint

type ProtocolDriver interface {// Start should establish connection(s) to endpoint(s). It is// called just once by the exporter, so the implementation// does not need to worry about idempotence and locking.Start(ctxcontext.Context)error// Stop should close the connections. The function is called// only once by the exporter, so the implementation does not// need to worry about idempotence, but it may be called// concurrently with ExportMetrics or ExportTraces, so proper// locking is required. The function serves as a// synchronization point - after the function returns, the// process of closing connections is assumed to be finished.Stop(ctxcontext.Context)error// ExportMetrics should transform the passed metrics to the// wire format and send it to the collector. May be called// concurrently with ExportTraces, so the manager needs to// take this into account by doing proper locking.ExportMetrics(ctxcontext.Context, cpsmetricsdk.CheckpointSet, selectormetricsdk.ExportKindSelector)error// ExportTraces should transform the passed traces to the wire// format and send it to the collector. May be called// concurrently with ExportMetrics, so the manager needs to// take this into account by doing proper locking.ExportTraces(ctxcontext.Context, ss []*tracesdk.SpanSnapshot)error}

funcNewSplitDriver¶added inv0.16.0

func NewSplitDriver(cfgSplitConfig)ProtocolDriver

NewSplitDriver creates a protocol driver which contains two otherprotocol drivers and will forward traces to one of them and metricsto another.

type SplitConfig struct {// ForMetrics driver will be used for sending metrics to the// collector.ForMetricsProtocolDriver// ForTraces driver will be used for sending spans to the// collector.ForTracesProtocolDriver}