Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for if (0.27 sec)

  1. istioctl/pkg/writer/compare/cluster.go

    	envoyClusterDump, err := c.envoy.GetDynamicClusterDump(true)
    	if err != nil {
    		envoyBytes.WriteString(err.Error())
    	} else {
    		envoy, err := protomarshal.ToJSONWithAnyResolver(envoyClusterDump, "    ", &envoyResolver)
    		if err != nil {
    			return err
    		}
    		envoyBytes.WriteString(envoy)
    	}
    	istiodClusterDump, err := c.istiod.GetDynamicClusterDump(true)
    	if err != nil {
    		istiodBytes.WriteString(err.Error())
    	} else {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Mar 12 10:02:09 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/envoy/configdump/cluster.go

    	if err != nil {
    		return err
    	}
    	if includeConfigType {
    		_, _ = fmt.Fprintln(w, "NAME\tSERVICE FQDN\tPORT\tSUBSET\tDIRECTION\tTYPE\tDESTINATION RULE")
    	} else {
    		_, _ = fmt.Fprintln(w, "SERVICE FQDN\tPORT\tSUBSET\tDIRECTION\tTYPE\tDESTINATION RULE")
    	}
    	for _, c := range clusters {
    		if filter.Verify(c) {
    			if len(strings.Split(c.Name, "|")) > 3 {
    				direction, subset, fqdn, port := model.ParseSubsetKey(c.Name)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu May 11 05:38:17 GMT 2023
    - 5.9K bytes
    - Viewed (0)
  3. istioctl/pkg/util/configdump/cluster.go

    	clusterDump, err := w.GetClusterConfigDump()
    	if err != nil {
    		return nil, err
    	}
    	dac := clusterDump.GetDynamicActiveClusters()
    	// Allow sorting to work even if we don't have the exact same type
    	for i := range dac {
    		dac[i].Cluster.TypeUrl = v3.ClusterType
    	}
    	sort.Slice(dac, func(i, j int) bool {
    		cluster := &cluster.Cluster{}
    		err = dac[i].Cluster.UnmarshalTo(cluster)
    		if err != nil {
    			return false
    		}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 2.1K bytes
    - Viewed (0)
  4. istioctl/pkg/multicluster/cluster.go

    func clusterUID(client kubernetes.Interface) (types.UID, error) {
    	kubeSystem, err := client.CoreV1().Namespaces().Get(context.TODO(), "kube-system", metav1.GetOptions{})
    	if err != nil {
    		return "", err
    	}
    	return kubeSystem.UID, nil
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Sep 02 03:11:58 GMT 2022
    - 1.1K bytes
    - Viewed (0)
Back to top