- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 22 for Req (3.36 sec)
-
pilot/pkg/networking/core/cluster_builder_test.go
setH2Options(ec) } destRule := proxy.SidecarScope.DestinationRule(model.TrafficDirectionOutbound, proxy, tt.service.Hostname) eb := endpoints.NewCDSEndpointBuilder(proxy, cb.req.Push, tt.cluster.Name, model.TrafficDirectionOutbound, "", tt.service.Hostname, tt.port.Port, tt.service, destRule)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
kl.logServer = http.StripPrefix("/logs/", http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { if nlq, errs := newNodeLogQuery(req.URL.Query()); len(errs) > 0 { http.Error(w, errs.ToAggregate().Error(), http.StatusBadRequest) return } else if nlq != nil { if req.URL.Path != "/" && req.URL.Path != "" { http.Error(w, "path not allowed in query mode", http.StatusNotAcceptable)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
fastapi/applications.py
if self.openapi_url: urls = (server_data.get("url") for server_data in self.servers) server_urls = {url for url in urls if url} async def openapi(req: Request) -> JSONResponse: root_path = req.scope.get("root_path", "").rstrip("/") if root_path not in server_urls: if root_path and self.root_path_in_servers:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat May 18 00:48:03 UTC 2024 - 172.2K bytes - Viewed (0) -
src/crypto/x509/x509_test.go
FioUxb6UKdHcPLR1VZtAdTdTMjSJxUqD/35Cdfqs7oDJXz8f6TXO2Tdy6G++YUs9 qsGZWxzFvvkXUkQSl0dQQ5jO/FtUJcAVXVVp20LxPemfatAHpW31WdJYeWSQWky2 +f9b5TXKXVyjlUL7uHxowWrT2AtTchDH22wTEtqLEF9Z3Q== -----END CERTIFICATE-----` // openssl req -newkey rsa:2048 -keyout test.key -sha256 -sigopt \ // rsa_padding_mode:pss -sigopt rsa_pss_saltlen:32 -sigopt rsa_mgf1_md:sha256 \ // -x509 -days 3650 -nodes -subj '/C=US/ST=CA/L=SF/O=Test/CN=Test' -out \ // test.pem
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:00:16 UTC 2024 - 163.4K bytes - Viewed (0) -
cmd/admin-handlers.go
defer cancel() ki := madmin.KubernetesInfo{} req, err := http.NewRequestWithContext(ctx, http.MethodGet, kubernetesVersionEndpoint, nil) if err != nil { ki.Error = err.Error() return ki } client := &http.Client{ Transport: globalRemoteTargetTransport, Timeout: 10 * time.Second, } resp, err := client.Do(req) if err != nil { ki.Error = err.Error() return ki
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
return containerStatuses } // ServeLogs returns logs of current machine. func (kl *Kubelet) ServeLogs(w http.ResponseWriter, req *http.Request) { // TODO: allowlist logs we are willing to serve kl.logServer.ServeHTTP(w, req) } // findContainer finds and returns the container with the given pod ID, full name, and container name. // It returns nil if not found.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
cmd/bucket-replication.go
Path: healthCheckPathPrefix + healthCheckReadinessPath, } req, err := http.NewRequestWithContext(ctx, http.MethodGet, reqURL.String(), nil) if err != nil { return err } client := &http.Client{ Transport: globalRemoteTargetTransport, Timeout: 10 * time.Second, } resp, err := client.Do(req) if err != nil { return err } if err == nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
tests/integration/pilot/common/routing.go
}, Port: echo.Port{ServicePort: ports.HTTP.ServicePort, Protocol: protocol.HTTP}, Check: check.And( check.OK(), ConsistentHostChecker, ), PropagateResponse: func(req *http.Request, res *http.Response) { scopes.Framework.Infof("invoking propagate response") if res == nil { scopes.Framework.Infof("no response") return } if res.Cookies() == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 21:52:51 UTC 2024 - 135.9K bytes - Viewed (0) -
src/cmd/vendor/github.com/ianlancetaylor/demangle/ast.go
if len(re.Params) > 0 { ps.writeByte(' ') ps.startScope('(') ps.printList(re.Params, nil) ps.endScope(')') } ps.writeByte(' ') ps.startScope('{') for _, req := range re.Requirements { ps.print(req) } ps.writeByte(' ') ps.endScope('}') } func (re *RequiresExpr) Traverse(fn func(AST) bool) { if fn(re) { for _, p := range re.Params { p.Traverse(fn)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 105.8K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal_test.go
return } reported := 0 for _, r := range tc.reportedLevels { reported += int(r) } requested := 0 for _, req := range tc.reportedCPURequests { requested += int(req.MilliValue()) } tc.CPUCurrent = int32(100 * reported / requested) } func init() { // set this high so we don't accidentally run into it when testing scaleUpLimitFactor = 8
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 199.3K bytes - Viewed (0)