- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for Sood (0.12 sec)
-
istioctl/pkg/util/handlers/handlers.go
if err != nil { return "", "", err } if podName != "" { return podName, namespace, nil } // We need to pass in a sorter, and the one used by `kubectl logs` is good enough. sortBy := func(pods []*corev1.Pod) sort.Interface { return podutils.ByLogging(pods) } timeout := 2 * time.Second if getFirstPodFunc == nil { getFirstPodFunc = polymorphichelpers.GetFirstPod }
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) -
cni/pkg/nodeagent/ztunnelserver.go
// something first, we expect to get an os.ErrDeadlineExceeded error // here if the connection is still alive. // note that unlike tcp connections, reading is a good enough test here. _, err := conn.readMessage(time.Second / 100) switch { case !errors.Is(err, os.ErrDeadlineExceeded): log.Debugf("ztunnel keepalive failed: %v", err) if errors.Is(err, io.EOF) {
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) -
cni/pkg/nodeagent/informers.go
// pod was added to our cache // we get here in 2 cases: // 1. new pod was created on our node // 2. we were restarted and current existing pods are added to our cache // We have no good way to distinguish between these two cases from here. But we don't need to! // Existing pods will be handled by the dataplane using `GetAmbientPods`, // and the initial enqueueNamespace, and new pods will be handled by the CNI.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
istioctl/pkg/kubeinject/google.go
package kubeinject import ( "context" "fmt" "net/http" "strings" "golang.org/x/oauth2" "golang.org/x/oauth2/google" ) func isMCPAddr(addr string) bool { // A bit inexact but should be good enough. return strings.Contains(addr, ".googleapis.com/") || strings.Contains(addr, ".googleapis.com:443/") } func mcpTransport(ctx context.Context, tr http.RoundTripper) (http.RoundTripper, error) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.2K bytes - Viewed (0) -
cni/pkg/install/install.go
select { case <-watcher.Events: // Something changed, and we must yield return nil case err := <-watcher.Errors: // We had a watch error - that's no good return err case <-ctx.Done(): return ctx.Err() default: // Valid configuration; set isReady to true and wait for modifications before checking again setReady(in.isReady)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
}) if err != nil { return types.NamespacedName{}, err } pods := slices.Reference(podsr.Items) if len(pods) > 0 { // We need to pass in a sorter, and the one used by `kubectl logs` is good enough. sortBy := func(pods []*corev1.Pod) sort.Interface { return podutils.ByLogging(pods) } sort.Sort(sortBy(pods)) return config.NamespacedName(pods[0]), nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0)