- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 59 for timeout (0.35 sec)
-
internal/http/transports.go
return tr } } // NewHTTPTransportWithTimeout allows setting a timeout for response headers func (s ConnSettings) NewHTTPTransportWithTimeout(timeout time.Duration) *http.Transport { tr := s.getDefaultTransport(0) // Settings specific to this transport. tr.ResponseHeaderTimeout = timeout return tr } // NewHTTPTransportWithClientCerts returns a new http configuration used for
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.9K bytes - Viewed (0) -
internal/grid/grid_test.go
connRemoteLocal := remote.Connection(localHost) t.Run("testStreamRoundtrip", func(t *testing.T) { defer timeout(5 * time.Second)() testStreamRoundtrip(t, local, remote) assertNoActive(t, connRemoteLocal) assertNoActive(t, connLocalToRemote) }) t.Run("testStreamCancel", func(t *testing.T) { defer timeout(5 * time.Second)() testStreamCancel(t, local, remote) assertNoActive(t, connRemoteLocal)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers.go
sortBy := func(pods []*corev1.Pod) sort.Interface { return podutils.ByLogging(pods) } timeout := 2 * time.Second if getFirstPodFunc == nil { getFirstPodFunc = polymorphichelpers.GetFirstPod } pod, _, err := getFirstPodFunc(client, namespace, selector, timeout, sortBy) if err != nil { return "", "", fmt.Errorf("no pods match %q", resname) } return pod.Name, namespace, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 06 15:01:41 GMT 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/wait/wait_test.go
args: strings.Split("--timeout 20ms virtual-service bar.default", " "), wantException: true, expectedOutput: "Error: timeout expired before resource networking.istio.io/v1alpha3/VirtualService/default/bar became effective on all sidecars\n", }, { execClientConfig: cannedResponseMap, args: strings.Split("--timeout 2s virtualservice foo.default", " "), wantException: false,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 6.8K bytes - Viewed (1) -
cni/test/install_cni.go
if !chainedCNIPlugin { installConfig.InstallConfig.ChainedCNIPlugin = false } startInstallServer(ctx, &installConfig, t) } // checkResult checks if resultFile is equal to expectedFile at each tick until timeout func checkResult(result, expected string) error { resultFile, err := os.ReadFile(result) if err != nil { return fmt.Errorf("couldn't read result: %v", err) } expectedFile, err := os.ReadFile(expected)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
} responses := []*discovery.DiscoveryResponse{} xdsOpts := clioptions.CentralControlPlaneOptions{ XDSSAN: makeSan(istioNamespace, kubeClient.Revision()), CertDir: centralOpts.CertDir, Timeout: centralOpts.Timeout, } dialOpts, err := xds.DialOptions(xdsOpts, istioNamespace, tokenServiceAccount, kubeClient) if err != nil { return nil, err } for _, pod := range pods {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
internal/http/server.go
} // UseShutdownTimeout configure server shutdown timeout func (srv *Server) UseShutdownTimeout(d time.Duration) *Server { srv.ShutdownTimeout = d return srv } // UseIdleTimeout configure idle connection timeout func (srv *Server) UseIdleTimeout(d time.Duration) *Server { srv.IdleTimeout = d return srv } // UseReadHeaderTimeout configure read header timeout
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
} func (z *ZtunnelConnection) readMessage(timeout time.Duration) (*zdsapi.WorkloadResponse, error) { m, _, err := readProto[zdsapi.WorkloadResponse](z.u, timeout, nil) return m, err } func readProto[T any, PT interface { proto.Message *T }](c *net.UnixConn, timeout time.Duration, oob []byte) (PT, int, error) { var buf [1024]byte err := c.SetReadDeadline(time.Now().Add(timeout)) if err != nil { return nil, 0, err
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/update.go
} func getUpdateTransport(timeout time.Duration) http.RoundTripper { var updateTransport http.RoundTripper = &http.Transport{ Proxy: http.ProxyFromEnvironment, DialContext: xhttp.NewInternodeDialContext(timeout, globalTCPOptions), IdleConnTimeout: timeout, TLSHandshakeTimeout: timeout, ExpectContinueTimeout: timeout, TLSClientConfig: &tls.Config{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/admin-heal-ops.go
) const ( // a heal sequence with this many un-consumed heal result // items blocks until heal-status consumption resumes or is // aborted due to timeout. maxUnconsumedHealResultItems = 1000 // if no heal-results are consumed (via the heal-status API) // for this timeout duration, the heal sequence is aborted. healUnconsumedTimeout = 24 * time.Hour // time-duration to keep heal sequence state after it // completes.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1)