Function recoverClientPanic

server/flightclient/flight_executor.go:160–168

recoverClientPanic converts a nil-pointer panic from a closed Flight SQL client into an error. The arrow-go Close() method nils out the embedded FlightServiceClient, so any concurrent RPC on the shared client panics. Only nil-pointer dereferences are recovered; other panics are re-raised to preserve

(err *error)

// Flight SQL client. The client is NOT closed when this executor is closed.
// This avoids creating a new gRPC connection per session.
func NewFlightExecutorFromClient(client *flightsql.Client, sessionToken string) *FlightExecutor {
	return NewFlightExecutorFromClientWithQueryLogLimiter(client, sessionToken, nil)
}

// NewFlightExecutorFromClientWithQueryLogLimiter creates a per-session
// executor whose asynchronous query-log calls share a worker-wide limiter.
func NewFlightExecutorFromClientWithQueryLogLimiter(client *flightsql.Client, sessionToken string, limiter *QueryLogLimiter) *FlightExecutor {
	if limiter == nil {
		limiter = NewQueryLogLimiter()
	}
	ctx, cancel := context.WithCancel(context.Background())
	e := &FlightExecutor{