- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 4,590 for servec (0.39 sec)
-
src/net/http/fs_test.go
name string modtime time.Time content io.ReadSeeker contentType string etag string } servec := make(chan serveParam, 1) ts := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) { p := <-servec if p.etag != "" { w.Header().Set("ETag", p.etag) } if p.contentType != "" { w.Header().Set("Content-Type", p.contentType) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 23:39:44 UTC 2024 - 49.9K bytes - Viewed (0) -
src/net/rpc/server.go
} server.respLock.Unlock() return resp } func (server *Server) freeResponse(resp *Response) { server.respLock.Lock() resp.next = server.freeResp server.freeResp = resp server.respLock.Unlock() } func (server *Server) readRequest(codec ServerCodec) (service *service, mtype *methodType, req *Request, argv, replyv reflect.Value, keepReading bool, err error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 21.6K bytes - Viewed (0) -
src/net/http/httptest/server.go
// The caller should call Close when finished, to shut it down. func NewUnstartedServer(handler http.Handler) *Server { return &Server{ Listener: newLocalListener(), Config: &http.Server{Handler: handler}, } } // Start starts a server from NewUnstartedServer. func (s *Server) Start() { if s.URL != "" { panic("Server already started") } if s.client == nil { s.client = &http.Client{Transport: &http.Transport{}}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:26:10 UTC 2024 - 10.7K bytes - Viewed (0) -
cluster/addons/metrics-server/metrics-server-service.yaml
apiVersion: v1 kind: Service metadata: name: metrics-server namespace: kube-system labels: addonmanager.kubernetes.io/mode: Reconcile kubernetes.io/cluster-service: "true" kubernetes.io/name: "Metrics-server" spec: selector: k8s-app: metrics-server ports: - port: 443 protocol: TCP
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 03 20:14:57 UTC 2017 - 336 bytes - Viewed (0) -
internal/http/server.go
func (srv *Server) UseReadHeaderTimeout(d time.Duration) *Server { srv.ReadHeaderTimeout = d return srv } // UseHandler configure final handler for this HTTP *Server func (srv *Server) UseHandler(h http.Handler) *Server { srv.Handler = h return srv } // UseTLSConfig pass configured TLSConfig for this HTTP *Server func (srv *Server) UseTLSConfig(cfg *tls.Config) *Server { srv.TLSConfig = cfg return srv }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Feb 09 21:25:16 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/webhooks/validation/server/server.go
// DomainSuffix is the DNS domain suffix for Pilot CRD resources, // e.g. cluster.local. DomainSuffix string // Port where the webhook is served. the number should be greater than 1024 for non-root // user, because non-root user cannot bind port number less than 1024 // Mainly used for testing. Webhook server is started by Istiod. Port uint // Use an existing mux instead of creating our own. Mux *http.ServeMux }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 04 06:13:56 UTC 2024 - 9.3K bytes - Viewed (0) -
pkg/kubelet/server/server.go
os.Exit(1) } } // ListenAndServePodResources initializes a gRPC server to serve the PodResources service func ListenAndServePodResources(endpoint string, providers podresources.PodResourcesProviders) { server := grpc.NewServer(apisgrpc.WithRateLimiter("podresources", podresources.DefaultQPS, podresources.DefaultBurstTokens))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/mod/sumdb/server.go
} // A Server is the checksum database HTTP server, // which implements http.Handler and should be invoked // to serve the paths listed in [ServerPaths]. type Server struct { ops ServerOps } // NewServer returns a new Server using the given operations. func NewServer(ops ServerOps) *Server { return &Server{ops: ops} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jul 12 20:38:21 UTC 2023 - 4.9K bytes - Viewed (0) -
src/net/http/server.go
} // ErrServerClosed is returned by the [Server.Serve], [ServeTLS], [ListenAndServe], // and [ListenAndServeTLS] methods after a call to [Server.Shutdown] or [Server.Close]. var ErrServerClosed = errors.New("http: Server closed") // Serve accepts incoming connections on the Listener l, creating a // new service goroutine for each. The service goroutines read requests and // then call srv.Handler to reply to them.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
security/pkg/nodeagent/sds/server.go
) const ( maxStreams = 100000 maxRetryTimes = 5 ) // Server is the gPRC server that exposes SDS through UDS. type Server struct { workloadSds *sdsservice grpcWorkloadListener net.Listener grpcWorkloadServer *grpc.Server stopped *atomic.Bool } // NewServer creates and starts the Grpc server for SDS.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 07 17:44:41 UTC 2024 - 3.3K bytes - Viewed (0)