Function sendProfilingMetadata

duckdbservice/profiling.go:25–36

sendProfilingMetadata reads the profiling output file written by DuckDB and sends it as gRPC trailing metadata so the control plane can attach it to the trace span.

(ctx context.Context, session *Session)

// clearProfilingOutput removes the previous statement's profile before a
// statement begins. The returned timestamp is used to reject a profile that
// was not produced by this execution.
func clearProfilingOutput() time.Time {
	_ = os.Remove(profilingOutputPath)
	return time.Now()
}

func profilingMetadataSince(startedAt time.Time) string {
	info, err := os.Stat(profilingOutputPath)
	if err != nil || !info.ModTime().After(startedAt) {
		return ""
	}
	data, err := os.ReadFile(profilingOutputPath)
	if err != nil || len(data) == 0 {
		return ""
	}