Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for OK (0.32 sec)

  1. istioctl/pkg/writer/ztunnel/configdump/workload.go

    		return "None"
    	}
    
    	if svc, ok := services[wl.Waypoint.Destination]; ok {
    		return svc.Name
    	}
    
    	return "NA" // Shouldn't normally reach here
    }
    
    func serviceWaypointName(svc *ZtunnelService, services map[string]*ZtunnelService) string {
    	if svc.Waypoint == nil {
    		return "None"
    	}
    
    	if svc, ok := services[svc.Waypoint.Destination]; ok {
    		return svc.Name
    	}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 4K bytes
    - Viewed (0)
  2. istioctl/pkg/util/ambient/util.go

    	if client == nil {
    		return isZtunnel
    	}
    	pod, err := client.Kube().CoreV1().Pods(podNamespace).Get(context.Background(), podName, metav1.GetOptions{})
    	if err != nil {
    		return isZtunnel
    	}
    	if v, ok := pod.Labels["app"]; ok {
    		return v == "ztunnel"
    	}
    	return isZtunnel
    }
    
    // InAmbient returns true if a resource is in ambient data plane mode.
    func InAmbient(obj metav1.Object) bool {
    	if obj == nil {
    		return false
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu May 02 21:29:40 GMT 2024
    - 1.7K bytes
    - Viewed (0)
  3. cni/pkg/ipset/nldeps_linux.go

    	if v6 {
    		family = unix.AF_INET6
    	} else {
    		family = unix.AF_INET
    	}
    	err := netlink.IpsetCreate(name, "hash:ip", netlink.IpsetCreateOptions{Comments: true, Replace: true, Family: family})
    	if ipsetErr, ok := err.(nl.IPSetError); ok && ipsetErr == nl.IPSET_ERR_EXIST {
    		return nil
    	}
    
    	return err
    }
    
    func (m *realDeps) destroySet(name string) error {
    	err := netlink.IpsetDestroy(name)
    	return err
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/net.go

    	// in this case the CNI will be invoked soon and provide us with the netns.
    	openNetns = s.currentPodSnapshot.Get(string(pod.UID))
    	if openNetns == nil {
    		return nil, fmt.Errorf("can't find netns for pod, this is ok if this is a newly created pod (%w)", ErrPodNotFound)
    	}
    
    	return openNetns, nil
    }
    
    // AddPodToMesh adds a pod to mesh by
    // 1. Getting the netns
    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)
  5. cni/pkg/plugin/plugin.go

    	if pi.Containers.Contains(ISTIOINIT) {
    		log.Infof("excluded due to being already injected with istio-init container")
    		return nil
    	}
    
    	if val, ok := pi.ProxyEnvironments["DISABLE_ENVOY"]; ok {
    		if val, err := strconv.ParseBool(val); err == nil && val {
    			log.Infof("excluded due to DISABLE_ENVOY on istio-proxy", podNamespace, podName)
    			return nil
    		}
    	}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 15:58:51 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  6. istioctl/pkg/ztunnelconfig/ztunnelconfig.go

    			} else if loggerLevelString != "" {
    				levels := strings.Split(loggerLevelString, ",")
    				for _, ol := range levels {
    					if !strings.Contains(ol, ":") && !strings.Contains(ol, "=") {
    						level, ok := stringToLevel[ol]
    						if ok {
    							destLoggerLevels = map[string]Level{
    								defaultLoggerName: level,
    							}
    						} else {
    							return fmt.Errorf("unrecognized logging level: %v", ol)
    						}
    					} else {
    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)
Back to top