Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for enabled (0.25 sec)

  1. istioctl/pkg/util/ambient/util.go

    	}
    	switch t := obj.(type) {
    	case *corev1.Pod:
    		return t.GetAnnotations()[constants.AmbientRedirection] == constants.AmbientRedirectionEnabled
    	case *corev1.Namespace:
    		if t.GetLabels()["istio-injection"] == "enabled" {
    			return false
    		}
    		if v, ok := t.GetLabels()[label.IoIstioRev.Name]; ok && v != "" {
    			return false
    		}
    		return t.GetLabels()[constants.DataplaneModeLabel] == constants.DataplaneModeAmbient
    	}
    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)
  2. cni/pkg/plugin/plugin_test.go

                    "gateway": "10.0.0.1",
                    "interface": 0
                }
            ],
            "routes": []
    
        },
        "log_level": "debug",
        "cni_event_address": "%s",
        "ambient_enabled": %t,
        "kubernetes": {
            "k8s_api_root": "APIRoot",
            "kubeconfig": "testK8sConfig",
    		"intercept_type": "%s",
            "node_name": "testNodeName",
            "exclude_namespaces": ["testExcludeNS"],
    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. cni/pkg/util/podutil_test.go

    	}
    	tests := []struct {
    		name string
    		args args
    		want bool
    	}{
    		{
    			name: "ambient mode enabled for namespace",
    			args: args{
    				namespace: namespaceWithAmbientEnabledLabel,
    				pod:       unlabelledPod,
    			},
    			want: true,
    		},
    		{
    			name: "ambient mode enabled for pod",
    			args: args{
    				namespace: unlabelledNamespace,
    				pod:       podWithAmbientEnabledLabel,
    			},
    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)
  4. operator/cmd/mesh/install.go

    				return "", "", nil, fmt.Errorf("failed to check if component: %s is enabled or not: %v", string(c), err)
    			}
    			if enabled {
    				enabledComponents = append(enabledComponents, name.UserFacingComponentName(c))
    			}
    		}
    		for _, c := range iop.Spec.Components.IngressGateways {
    			if c.Enabled.GetValue() {
    				enabledComponents = append(enabledComponents, name.UserFacingComponentName(name.IngressComponentName))
    				break
    			}
    		}
    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)
  5. cni/pkg/config/config.go

    	ZtunnelUDSAddress string
    
    	// Whether ambient is enabled
    	AmbientEnabled bool
    
    	// Whether ambient DNS capture is enabled
    	AmbientDNSCapture bool
    
    	// Whether ipv6 is enabled for ambient capture
    	AmbientIPv6 bool
    }
    
    // RepairConfig struct defines the Istio CNI race repair configuration
    type RepairConfig struct {
    	// Whether to enable CNI race repair
    	Enabled bool
    
    	// The node name that the CNI DaemonSet runs on
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/net.go

    	}
    
    	return nil
    }
    
    func pruneHostIPset(expected sets.Set[netip.Addr], hostsideProbeSet *ipset.IPSet) error {
    	actualIPSetContents, err := hostsideProbeSet.ListEntriesByIP()
    	if err != nil {
    		log.Warnf("unable to list IPSet: %v", err)
    		return err
    	}
    	actual := sets.New[netip.Addr](actualIPSetContents...)
    	stales := actual.DifferenceInPlace(expected)
    
    	for staleIP := range stales {
    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)
  7. cni/pkg/nodeagent/informers.go

    	namespace := o.GetName()
    	labels := o.GetLabels()
    	matchAmbient := labels[constants.DataplaneModeLabel] == constants.DataplaneModeAmbient
    	if matchAmbient {
    		log.Infof("Namespace %s is enabled in ambient mesh", namespace)
    	} else {
    		log.Infof("Namespace %s is disabled from ambient mesh", namespace)
    	}
    	for _, pod := range s.pods.List(namespace, klabels.Everything()) {
    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)
  8. cni/pkg/constants/constants.go

    	ZtunnelUDSAddress    = "ztunnel-uds-address"
    	CNIEventAddress      = "cni-event-address"
    	AmbientEnabled       = "ambient-enabled"
    	AmbientDNSCapture    = "ambient-dns-capture"
    	AmbientIPv6          = "ambient-ipv6"
    
    	// Repair
    	RepairEnabled            = "repair-enabled"
    	RepairDeletePods         = "repair-delete-pods"
    	RepairRepairPods         = "repair-repair-pods"
    	RepairLabelPods          = "repair-label-pods"
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/informers_test.go

    			NodeName: NodeName,
    		},
    		Status: corev1.PodStatus{
    			PodIP: "11.1.1.12",
    		},
    	}
    	ns := &corev1.Namespace{
    		ObjectMeta: metav1.ObjectMeta{Name: "test"},
    		// TODO: once we if the add pod bug, re-enable this and remove the patch below
    		//		Labels: map[string]string{constants.DataplaneModeLabel: constants.DataplaneModeAmbient},
    
    	}
    
    	client := kube.NewFakeClient(ns, pod)
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  10. cni/pkg/plugin/plugin.go

    	LogLevel        string     `json:"log_level"`
    	LogUDSAddress   string     `json:"log_uds_address"`
    	CNIEventAddress string     `json:"cni_event_address"`
    	AmbientEnabled  bool       `json:"ambient_enabled"`
    	Kubernetes      Kubernetes `json:"kubernetes"`
    }
    
    // K8sArgs is the valid CNI_ARGS used for Kubernetes
    // The field names need to match exact keys in containerd args for unmarshalling
    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)
Back to top