private void onRequestResult(HttpServerExchange serverExchange, PooledConnection connection, boolean allowed) {
        connectionPools.get(serverExchange.getIoThread()).release(connection);
        // Remove attachment early to make it eligible for GC
        AuthContext context = serverExchange.removeAttachment(AUTH_CONTEXT_KEY);
        apiLatency.update(context.getClientResponseTime(), NANOSECONDS);
        authLatency.update(context.getLatency(), NANOSECONDS);
        if (allowed) {
            serverExchange.dispatch(containerHandler);
        } else {
            endExchange(serverExchange, FORBIDDEN);
        }
    }
private void onRequestResult(HttpServerExchange serverExchange, PooledConnection connection, boolean allowed) {
        connectionPools.get(serverExchange.getIoThread()).release(connection);
        
        AuthContext context = serverExchange.removeAttachment(AUTH_CONTEXT_KEY);
        apiLatency.update(context.getClientResponseTime(), NANOSECONDS);
        authLatency.update(context.getLatency(), NANOSECONDS);
        if (allowed) {
            serverExchange.dispatch(containerHandler);
        } else {
            endExchange(serverExchange, FORBIDDEN);
        }
    }
private void onRequestResult ( HttpServerExchange serverExchange , PooledConnection connection , boolean allowed ) { connectionPools . get ( serverExchange . getIoThread ( ) ) . release ( connection ) ; // Remove attachment early to make it eligible for GC AuthContext context = serverExchange . removeAttachment ( AUTH_CONTEXT_KEY ) ; apiLatency . update ( context . getClientResponseTime ( ) , NANOSECONDS ) ; authLatency . update ( context . getLatency ( ) , NANOSECONDS ) ; if ( allowed ) { serverExchange . dispatch ( containerHandler ) ; } else { endExchange ( serverExchange , FORBIDDEN ) ; } }
Called when the Kubernetes master server reponse has been inspected.
Called when the Kubernetes master server reponse has been inspected .