Function NewOTLPHTTPExporter

internal/telemetry/otlp_http_exporter.go:31–59

(endpoint string, timeout time.Duration, retries, batchSize int, flushEvery time.Duration)

}

func NewOTLPHTTPExporter(endpoint string, timeout time.Duration, retries, batchSize int, flushEvery time.Duration) *OTLPHTTPExporter {
	if timeout <= 0 {
		timeout = 1 * time.Second
	}
	if retries < 0 {
		retries = 0
	}
	if batchSize <= 0 {
		batchSize = 10
	}
	if flushEvery <= 0 {
		flushEvery = 1 * time.Second
	}
	return &OTLPHTTPExporter{
		endpoint: endpoint,
		httpClient: &http.Client{
			Timeout: timeout,
		},
		retries:    retries,
		batchSize:  batchSize,
		flushEvery: flushEvery,
		buffer: map[string][]map[string]any{
			"metrics": {},
			"events":  {},
			"traces":  {},
		},
		lastFlush: time.Now(),
	}
}

func (e *OTLPHTTPExporter) EmitMetric(name string, value float64, labels map[string]string) {
	e.enqueue("metrics", map[string]any{