Method flush

internal/telemetry/otlp_http_exporter.go:116–147

()

}

func (e *OTLPHTTPExporter) flush() {
	e.mu.Lock()
	buffers := map[string][]map[string]any{
		"metrics": append([]map[string]any(nil), e.buffer["metrics"]...),
		"events":  append([]map[string]any(nil), e.buffer["events"]...),
		"traces":  append([]map[string]any(nil), e.buffer["traces"]...),
	}
	e.buffer["metrics"] = nil
	e.buffer["events"] = nil
	e.buffer["traces"] = nil
	e.lastFlush = time.Now()
	e.mu.Unlock()

	for kind, records := range buffers {
		if len(records) == 0 {
			continue
		}
		endpoint := endpointForKind(e.endpoint, kind)
		payload := buildPayload(kind, records)
		if err := e.post(endpoint, payload); err != nil {
			e.mu.Lock()
			e.lastError = err.Error()
			e.mu.Unlock()
		} else {
			e.mu.Lock()
			e.sentBatches++
			e.sentRecords += len(records)
			e.lastError = ""
			e.mu.Unlock()
		}
	}
}

func (e *OTLPHTTPExporter) post(endpoint string, payload map[string]any) error {
	raw, err := json.Marshal(payload)