Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for Len (0.11 sec)

  1. cni/pkg/util/podutil_test.go

    	podIPs := GetPodIPsIfPresent(pod)
    	assert.Equal(t, len(podIPs), 2)
    }
    
    func TestGetPodIPsIfNoPodIPPresent(t *testing.T) {
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: "derp",
    		},
    		Status: corev1.PodStatus{},
    	}
    
    	podIPs := GetPodIPsIfPresent(pod)
    	assert.Equal(t, len(podIPs), 0)
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  2. cni/pkg/plugin/plugin_test.go

    	pod.ObjectMeta.Annotations[sidecarStatusKey] = "true"
    
    	mockIntercept := testDoAddRun(t, buildMockConf(false, ""), testNSName, pod, ns)
    
    	if len(mockIntercept.lastRedirect) == 0 {
    		t.Fatalf("expected nsenterFunc to be called")
    	}
    	r := mockIntercept.lastRedirect[len(mockIntercept.lastRedirect)-1]
    	if r.includeInboundPorts != "*" {
    		t.Fatalf("expect includeInboundPorts has value '*' set by istio, actual %v", r.includeInboundPorts)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 15:58:51 GMT 2024
    - 17.5K bytes
    - Viewed (0)
  3. istioctl/pkg/waypoint/waypoint.go

      istioctl x waypoint delete --all --namespace default`,
    		Args: func(cmd *cobra.Command, args []string) error {
    			if deleteAll && len(args) > 0 {
    				return fmt.Errorf("cannot specify waypoint names when deleting all waypoints")
    			}
    			if !deleteAll && len(args) == 0 {
    				return fmt.Errorf("must either specify a waypoint name or delete all using --all")
    			}
    			return nil
    		},
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 19:45:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/ztunnel/configdump/certificates.go

    			secret.State = "Unavailable"
    		}
    		if len(secret.CertChain) == 0 {
    			fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\t%v\t%v\n",
    				secret.Identity, valueOrNA(""), secret.State, false, valueOrNA(""), valueOrNA(""), valueOrNA(""))
    		} else {
    			for i, ca := range secret.CertChain {
    				t := "Intermediate"
    				if i == 0 {
    					t = "Leaf"
    				} else if i == len(secret.CertChain)-1 {
    					t = "Root"
    				}
    				n := new(big.Int)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 25 16:38:16 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/ztunnel/configdump/workload.go

    func (c *ConfigWriter) PrintWorkloadSummary(filter WorkloadFilter) error {
    	w := c.tabwriter()
    	zDump := c.ztunnelDump
    
    	verifiedWorkloads := make([]*ZtunnelWorkload, 0, len(zDump.Workloads))
    	for _, wl := range zDump.Workloads {
    		if filter.Verify(wl) {
    			verifiedWorkloads = append(verifiedWorkloads, wl)
    		}
    	}
    
    	// Sort by name, node
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 4K bytes
    - Viewed (0)
  6. operator/cmd/mesh/install.go

    }
    
    func humanReadableJoin(ss []string) string {
    	switch len(ss) {
    	case 0:
    		return ""
    	case 1:
    		return ss[0]
    	case 2:
    		return ss[0] + " and " + ss[1]
    	default:
    		return strings.Join(ss[:len(ss)-1], ", ") + ", and " + ss[len(ss)-1]
    	}
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu May 02 14:30:43 GMT 2024
    - 15.5K bytes
    - Viewed (1)
  7. istioctl/pkg/writer/ztunnel/configdump/services.go

    			return r
    		}
    		return cmp.Compare(a.Hostname, b.Hostname)
    	})
    	fmt.Fprintln(w, "NAMESPACE\tSERVICE NAME\tSERVICE VIP\tWAYPOINT")
    
    	for _, svc := range svcs {
    		var ip string
    		if len(svc.Addresses) > 0 {
    			_, ip, _ = strings.Cut(svc.Addresses[0], "/")
    		}
    		waypoint := serviceWaypointName(svc, zDump.Services)
    		fmt.Fprintf(w, "%v\t%v\t%v\t%v\n",
    			svc.Namespace, svc.Name, ip, waypoint)
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  8. manifests/charts/istio-control/istio-discovery/files/grpc-agent.yaml

      annotations: {
        istio.io/rev: {{ .Revision | default "default" | quote }},
        {{- if ge (len $containers) 1 }}
        {{- if not (isset .ObjectMeta.Annotations `kubectl.kubernetes.io/default-logs-container`) }}
        kubectl.kubernetes.io/default-logs-container: "{{ index $containers 0 }}",
        {{- end }}
    Others
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 26 16:51:17 GMT 2024
    - 12.1K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/informers.go

    			// it's not routable at this point and something is wrong/we should discard this event.
    			podIPs := util.GetPodIPsIfPresent(pod)
    			if len(podIPs) == 0 {
    				log.Warnf("pod %s does not appear to have any assigned IPs, not capturing", pod.Name)
    				return nil
    			}
    
    			err := s.dataplane.AddPodToMesh(s.ctx, pod, podIPs, "")
    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)
  10. cni/pkg/nodeagent/net.go

    	return nil
    }
    
    func (s *NetServer) syncHostIPSets(ambientPods []*corev1.Pod) error {
    	var addedIPSnapshot []netip.Addr
    
    	for _, pod := range ambientPods {
    		podIPs := util.GetPodIPsIfPresent(pod)
    		if len(podIPs) == 0 {
    			log.Warnf("pod %s does not appear to have any assigned IPs, not syncing with ipset", pod.Name)
    		} else {
    			err := addPodToHostNSIpset(pod, podIPs, &s.hostsideProbeIPSet)
    			if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
Back to top