- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for opt (0.15 sec)
-
istioctl/pkg/writer/envoy/configdump/ecds_test.go
gotOut := &bytes.Buffer{} cw := &ConfigWriter{Stdout: gotOut} cd, _ := os.ReadFile("testdata/ecds/configdump.json") cw.Prime(cd) err := cw.PrintEcds("json") assert.NoError(t, err) // protojson opt out of whitespace randomization, see more details: https://github.com/golang/protobuf/issues/1082 var rm json.RawMessage = gotOut.Bytes() jsonOutput, err := json.MarshalIndent(rm, "", " ") if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Dec 13 01:08:07 GMT 2022 - 1.9K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
func (s *NetServer) RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error { log := log.WithLabels("ns", pod.Namespace, "name", pod.Name) log.Debugf("Pod is now opt out... cleaning up.") openNetns := s.currentPodSnapshot.Take(string(pod.UID)) if openNetns == nil { log.Warn("failed to find pod netns") return fmt.Errorf("failed to find pod 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) -
cni/test/install_cni.go
cniNetworkConfig = `{ "cniVersion": "0.3.1", "type": "istio-cni", "log_level": "info", "kubernetes": { "kubeconfig": "__KUBECONFIG_FILEPATH__", "cni_bin_dir": "/opt/cni/bin", "exclude_namespaces": [ "istio-system" ] } } ` ) func getEnv(key, fallback string) string { if value, ok := os.LookupEnv(key); ok { return value } return fallback }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
pod.Spec.Containers = []corev1.Container{app} testDoAddRun(t, cniConf, testNSName, pod, ns) wasCalled := serverClose() // Pod has an explicit opt-out label, should not be added to ambient mesh assert.Equal(t, wasCalled, false) } func TestCmdAddPodEnabledNamespaceDisabled(t *testing.T) { url, serverClose := setupCNIEventClientWithMockServer(false)
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) -
istioctl/pkg/multicluster/remote_secret.go
if opt.ServiceAccountName == "" { opt.ServiceAccountName = constants.DefaultServiceAccountName } case SecretTypeConfig: secretName = configSecretName if opt.ServiceAccountName == "" { opt.ServiceAccountName = constants.DefaultConfigServiceAccountName } default: return nil, nil, fmt.Errorf("unsupported type: %v", opt.Type) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 11 01:43:17 GMT 2023 - 24K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
// Existing pods will be handled by the dataplane using `GetAmbientPods`, // and the initial enqueueNamespace, and new pods will be handled by the CNI. case controllers.EventUpdate: // For update, we just need to handle opt outs newPod := event.New.(*corev1.Pod) oldPod := event.Old.(*corev1.Pod) ns := s.namespaces.Get(newPod.Namespace, "") if ns == nil { return fmt.Errorf("failed to find namespace %v", ns) }
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) -
cni/pkg/constants/constants.go
LivenessEndpoint = "/healthz" ReadinessEndpoint = "/readyz" ReadinessPort = "8000" ) // Exposed for testing constants var ( CNIBinDir = "/opt/cni/bin" HostCNIBinDir = "/host/opt/cni/bin" ServiceAccountPath = "/var/run/secrets/kubernetes.io/serviceaccount" // Well-known subpath we will mount any needed host-mounts under, // to preclude shadowing or breaking any pod-internal mounts
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) -
istioctl/cmd/root.go
"log_as_json", "log_rotate", "log_rotate_max_age", "log_rotate_max_backups", "log_rotate_max_size", "log_stacktrace_level", "log_target", "log_caller", "log_output_level", } for _, opt := range hiddenFlags { _ = rootCmd.PersistentFlags().MarkHidden(opt) } cmd.AddFlags(rootCmd) kubeInjectCmd := kubeinject.InjectCommand(ctx) hideInheritedFlags(kubeInjectCmd, cli.FlagNamespace) rootCmd.AddCommand(kubeInjectCmd)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 11 20:51:30 GMT 2024 - 10K bytes - Viewed (0) -
cni/pkg/util/podutil.go
// Neither namespace nor pod has ambient mode enabled return false } if podHasSidecar(pod) { // Ztunnel and sidecar for a single pod is currently not supported; opt out. return false } if pod.GetLabels()[constants.DataplaneModeLabel] == constants.DataplaneModeNone { // Pod explicitly asked to not have ambient redirection enabled return false } return true }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 3.9K bytes - Viewed (0)