Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for pickers (0.15 sec)

  1. cni/pkg/iptables/iptables.go

    	// so that it could distinguish things that can be unauthenticated (healthchecks) from other kinds of node traffic
    	// (e.g. LoadBalanced Service packets, etc) that need to be authenticated/captured/proxied.
    	//
    	// We want to do the same thing in ambient but can't rely on podSpec injection. So, do effectively the same thing,
    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)
  2. cni/pkg/install/install_test.go

    				t.Fatal(err)
    			}
    
    			// Listen for isReady to be set to true
    			ticker := time.NewTicker(500 * time.Millisecond)
    			defer ticker.Stop()
    			readyChan := make(chan bool)
    			go func(ctx context.Context, tick <-chan time.Time) {
    				for {
    					select {
    					case <-ctx.Done():
    						return
    					case <-tick:
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 11.1K bytes
    - Viewed (0)
  3. cni/pkg/iptables/iptables_linux.go

    	if cfg.EnableIPv6 {
    		families = append(families, unix.AF_INET6)
    	}
    	for _, family := range families {
    		// Equiv:
    		// ip rule add fwmark 0x111/0xfff pref 32764 lookup 100
    		//
    		// Adds in-pod rules for marking packets with the istio-specific TPROXY mark.
    		// A very similar mechanism is used for sidecar TPROXY.
    		//
    		// TODO largely identical/copied from tools/istio-iptables/pkg/capture/run_linux.go
    		inpodMarkRule := netlink.NewRule()
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.3K bytes
    - Viewed (0)
  4. istioctl/pkg/waypoint/waypoint.go

    				}
    				return err
    			}
    			if waitReady {
    				startTime := time.Now()
    				ticker := time.NewTicker(1 * time.Second)
    				defer ticker.Stop()
    				for range ticker.C {
    					programmed := false
    					gwc, err := kubeClient.GatewayAPI().GatewayV1().Gateways(ctx.NamespaceOrDefault(ctx.Namespace())).Get(context.TODO(), gw.Name, metav1.GetOptions{})
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 19:45:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  5. istioctl/pkg/wait/wait.go

    			targetResource := config.Key(
    				targetSchema.Group(), targetSchema.Version(), targetSchema.Kind(),
    				nameflag, namespace)
    			for {
    				// run the check here as soon as we start
    				// because tickers won't run immediately
    				present, notpresent, sdcnum, err := poll(cliCtx, cmd, generations, targetResource, proxyFlag, opts)
    				printVerbosef(cmd, "Received poll result: %d/%d", present, present+notpresent)
    				if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Feb 17 12:24:17 GMT 2024
    - 10.1K bytes
    - Viewed (0)
  6. istioctl/pkg/workload/workload.go

    	configureCmd.PersistentFlags().BoolVar(&dnsCapture, "capture-dns", true, "Enables the capture of outgoing DNS packets on port 53, redirecting to istio-agent")
    	configureCmd.PersistentFlags().StringVar(&internalIP, "internalIP", "", "Internal IP address of the workload")
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Apr 17 20:06:41 GMT 2024
    - 25.5K bytes
    - Viewed (0)
Back to top