- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 150 for resps (0.48 sec)
-
pkg/dns/client/dns_test.go
mux := dns.NewServeMux() mux.HandleFunc(".", func(resp dns.ResponseWriter, msg *dns.Msg) { answer := new(dns.Msg) answer.SetReply(msg) answer.Rcode = dns.RcodeNameError if err := resp.WriteMsg(answer); err != nil { t.Fatalf("err: %s", err) } }) for hn, desiredResp := range responses { mux.HandleFunc(hn, func(resp dns.ResponseWriter, msg *dns.Msg) { answer := dns.Msg{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 16:17:34 UTC 2024 - 20.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware_test.go
// Verify we get the correct response and message body content resp, err := http.ReadResponse(bufferedReader, nil) require.NoError(t, err) assert.Equal(t, tc.expectStatusCode, resp.StatusCode) data, err := io.ReadAll(resp.Body) require.NoError(t, err) assert.Equal(t, tc.expectBody, data) assert.Equal(t, int64(len(tc.expectBody)), resp.ContentLength) resp.Body.Close() // clean up conn.Close() })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 10 07:29:34 UTC 2023 - 39.4K bytes - Viewed (0) -
src/net/smtp/smtp.go
err = &textproto.Error{Code: code, Msg: msg64} } if err == nil { resp, err = a.Next(msg, code == 334) } if err != nil { // abort the AUTH c.cmd(501, "*") c.Quit() break } if resp == nil { break } resp64 = make([]byte, encoding.EncodedLen(len(resp))) encoding.Encode(resp64, resp) code, msg64, err = c.cmd(0, "%s", resp64) } return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 11.6K bytes - Viewed (0) -
pilot/pkg/bootstrap/server_test.go
}() t.Run("h1", func(t *testing.T) { c := http.Client{} defer c.CloseIdleConnections() resp, err := c.Get("http://" + s.httpAddr + "/validate") assert.NoError(t, err) // Validate returns 400 on no body; if we got this the request works assert.Equal(t, resp.StatusCode, 400) resp.Body.Close() }) t.Run("h2", func(t *testing.T) { c := http.Client{ Transport: &http2.Transport{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 23.1K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/lds.go
filter := newListenerNameFilter(names, node) log.Debugf("building lds for %s with filter:\n%v", node.ID, filter) resp := make(model.Resources, 0, len(filter)) resp = append(resp, buildOutboundListeners(node, push, filter)...) resp = append(resp, buildInboundListeners(node, push, filter.inboundNames())...) return resp } func buildInboundListeners(node *model.Proxy, push *model.PushContext, names []string) model.Resources {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 14.6K bytes - Viewed (0) -
pkg/kubelet/logs/container_log_manager.go
c.mutex.Lock() defer c.mutex.Unlock() resp, err := c.runtimeService.ContainerStatus(ctx, containerID, false) if err != nil { return fmt.Errorf("failed to get container status %q: %v", containerID, err) } if resp.GetStatus() == nil { return fmt.Errorf("container status is nil for %q", containerID) } pattern := fmt.Sprintf("%s*", resp.GetStatus().GetLogPath()) logs, err := c.osInterface.Glob(pattern)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 15K bytes - Viewed (0) -
internal/grid/muxclient.go
} err := context.Cause(m.ctx) if !errors.Is(err, errStreamEOF) { m.addErrorNonBlockingClose(respHandler, err) } return case resp, ok := <-respServer: if !ok { return } sendResp: select { case respHandler <- resp: m.respMu.Lock() if !m.closed { gridLogIf(m.ctx, m.sendLocked(message{Op: OpUnblockSrvMux, MuxID: m.MuxID})) } m.respMu.Unlock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
pilot/test/xdstest/extract.go
func UnmarshalRouteConfiguration(t test.Failer, resp []*anypb.Any) []*route.RouteConfiguration { un := make([]*route.RouteConfiguration, 0, len(resp)) for _, r := range resp { u := &route.RouteConfiguration{} if err := r.UnmarshalTo(u); err != nil { t.Fatal(err) } un = append(un, u) } return un } func UnmarshalClusterLoadAssignment(t test.Failer, resp []*anypb.Any) []*endpoint.ClusterLoadAssignment {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 13.9K bytes - Viewed (0) -
pkg/scheduler/extender.go
return err } req.Header.Set("Content-Type", "application/json") resp, err := h.client.Do(req) if err != nil { return err } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { return fmt.Errorf("failed %v with extender at URL %v, code %v", action, url, resp.StatusCode) } return json.NewDecoder(resp.Body).Decode(result) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.4K bytes - Viewed (0) -
pkg/kubelet/server/server.go
} handlePprofEndpoint := func(req *restful.Request, resp *restful.Response) { name := strings.TrimPrefix(req.Request.URL.Path, pprofBasePath) switch name { case "profile": pprof.Profile(resp, req.Request) case "symbol": pprof.Symbol(resp, req.Request) case "cmdline": pprof.Cmdline(resp, req.Request) case "trace": pprof.Trace(resp, req.Request) default: pprof.Index(resp, req.Request)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0)