Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for because (0.15 sec)

  1. cni/pkg/nodeagent/net.go

    // - this is because during add specifically, if CNI plugins have not finished executing,
    // K8S may get a pod Add event without any IPs in the object, and the pod will later be updated with IPs.
    //
    // We always need the IPs, but this is fine because this AddPodToMesh can be called from the CNI plugin as well,
    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)
  2. cni/pkg/log/uds_test.go

    	assert.NoError(t, log.Configure(loggingOptions))
    	log.FindScope("default").SetOutputLevel(log.DebugLevel)
    	log.Debug("debug log")
    	log.Info("info log")
    	log.Warn("warn log")
    	log.Error("error log")
    	// This will error because stdout cannot sync, but the UDS part should sync
    	// Ideally we would fail if the UDS part fails but the error library makes it kind of tricky
    	_ = log.Sync()
    
    	// Restore os stdout.
    	os.Stdout = stdout
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Mar 16 00:20:01 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  3. istioctl/pkg/multixds/gather.go

    				touchedPods++
    				if options.XdsViaAgentsLimit != 0 && touchedPods > options.XdsViaAgentsLimit {
    					fmt.Fprintf(options.MessageWriter, "Some proxies may be missing from the list"+
    						" because the number of visited pod hits the limit %d,"+
    						" which can be set by `--xds-via-agents-limit` flag.\n", options.XdsViaAgentsLimit)
    					break GetProxyLoop
    				}
    				namespacedName := pod.Name + "." + pod.Namespace
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 08 08:38:19 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  4. istioctl/pkg/xds/client.go

    		// nolint: gosec
    		// Only runs over istioctl experimental
    		// TODO: https://github.com/istio/istio/issues/41937
    		grpc.WithTransportCredentials(credentials.NewTLS(
    			&tls.Config{
    				// Always skip verifying, because without it we always get "certificate signed by unknown authority".
    				// We don't set the XDSSAN for the same reason.
    				InsecureSkipVerify: true,
    			})),
    		grpc.WithPerRPCCredentials(k8sCreds),
    	}, nil
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Dec 19 22:42:42 GMT 2023
    - 3.7K bytes
    - Viewed (0)
  5. cni/pkg/iptables/iptables.go

    	// and kubelet (skippable) traffic would have the same srcip once they got to the pod, and would be indistinguishable.
    	//
    	// Note that SortedList is used here because the istio sets class has no order guarantees,
    	// and our unit tests will flake if rules have a nondeterministic ordering.
    	// CLI: -t mangle -A ISTIO_PRERT -s 169.254.7.127 -p tcp -m tcp --dport <PROBEPORT> -j ACCEPT
    	//
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue May 07 19:54:50 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  6. cni/pkg/install/cniconfig.go

    		return cniConfigFilepath, err
    	}
    
    	if cfg.chainedCNIPlugin && strings.HasSuffix(cniConfigFilepath, ".conf") {
    		// If the old CNI config filename ends with .conf, rename it to .conflist, because it has to be changed to a list
    		installLog.Infof("Renaming %s extension to .conflist", cniConfigFilepath)
    		err = os.Rename(cniConfigFilepath, cniConfigFilepath+"list")
    		if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  7. cni/pkg/plugin/plugin_test.go

    	pod.Spec.Containers[1].Name = "istio-proxy"
    
    	mockIntercept := testDoAddRun(t, buildMockConf(true, ""), testNSName, pod, ns)
    
    	if len(mockIntercept.lastRedirect) != 0 {
    		t.Fatalf("Didnt Expect nsenterFunc to be called because this pod does not contain a sidecar")
    	}
    }
    
    func TestCmdAddExcludePod(t *testing.T) {
    	pod, ns := buildFakePodAndNSForClient()
    
    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)
  8. cni/pkg/nodeagent/ztunnelserver_test.go

    }
    
    func podAndNetns() (*v1.Pod, *fakeNs) {
    	devNull, err := os.Open(os.DevNull)
    	if err != nil {
    		panic(err)
    	}
    	// we can't close this now, because we need to pass it from the ztunnel server to the client
    	// it would leak, but this is a test, so we don't care
    	//	defer devNull.Close()
    
    	id := ztunnelTestCounter.Add(1)
    	pod := &v1.Pod{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 8.6K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/informers.go

    	}))
    
    	// Namespaces could be anything though, so we watch all of those
    	//
    	// NOTE that we are requeueing namespaces here explicitly to work around
    	// test flakes with the fake kube client in `pkg/kube/client.go` -
    	// because we are using `List()` in the handler, without this requeue,
    	// the fake client will sometimes drop pod events leading to test flakes.
    	//
    	// WaitForCacheSync *helps*, but does not entirely fix this problem
    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. istioctl/pkg/proxyconfig/proxyconfig_test.go

    		{ // supplying valid pod name retrieves Envoy config (fails because we don't check in Envoy config unit tests)
    			execClientConfig: loggingConfig,
    			args:             strings.Split("clusters httpbin-794b576b6c-qx6pf", " "),
    			expectedString:   `config dump has no configuration type`,
    			wantException:    true,
    		},
    		{ // supplying valid pod name retrieves Envoy config (fails because we don't check in Envoy config unit tests)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Apr 10 21:51:29 GMT 2024
    - 8.9K bytes
    - Viewed (0)
Back to top