Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for respHandler (2.38 sec)

  1. internal/grid/muxclient.go

    func (m *muxClient) addErrorNonBlockingClose(respHandler chan<- Response, err error) {
    	m.respMu.Lock()
    	defer m.respMu.Unlock()
    	if !m.closed {
    		m.respErr.Store(&err)
    		// Do not block.
    		select {
    		case respHandler <- Response{Err: err}:
    			xioutil.SafeClose(respHandler)
    		default:
    			go func() {
    				respHandler <- Response{Err: err}
    				xioutil.SafeClose(respHandler)
    			}()
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/negotiation/negotiate.go

    	if !ok {
    		supported, _ := MediaTypesForSerializer(ns)
    		return mediaType, runtime.SerializerInfo{}, NewNotAcceptableError(supported)
    	}
    	// TODO: move into resthandler
    	info := mediaType.Accepted
    	if (mediaType.Pretty || isPrettyPrint(req)) && info.PrettySerializer != nil {
    		info.Serializer = info.PrettySerializer
    	}
    	return mediaType, info, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 10 10:53:34 UTC 2019
    - 9.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go

    	// LoopbackClientConfig is a config for a privileged loopback connection to the API server
    	LoopbackClientConfig *restclient.Config
    
    	// minRequestTimeout is how short the request timeout can be.  This is used to build the RESTHandler
    	minRequestTimeout time.Duration
    
    	// ShutdownTimeout is the timeout used for server shutdown. This specifies the timeout before server
    	// gracefully shutdown returns.
    	ShutdownTimeout time.Duration
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 42.9K bytes
    - Viewed (0)
Back to top