- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for respHandler (2.38 sec)
-
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) -
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) -
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)