Function closeTelemetry

pkg/cmd/root/root.go:326–340

closeTelemetry flushes the pending telemetry events, giving up after a short timeout so an unreachable telemetry endpoint never delays exit.

(ctx context.Context)

// closeTelemetry flushes the pending telemetry events, giving up after a
// short timeout so an unreachable telemetry endpoint never delays exit.
func closeTelemetry(ctx context.Context) {
	client := telemetry.GetTelemetryClient(ctx)
	if client == nil {
		return
	}
	done := make(chan struct{})
	go func() {
		client.Close()
		close(done)
	}()
	select {
	case <-done:
	case <-time.After(500 * time.Millisecond):
	}
}

// createContext creates a context with telemetry.
func createContext(