Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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)
  2. 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)
  3. cni/README.md

    |--------------------|-----------------|-----------------------------------------------------------------------------------------------------------------------------------------------|
    | HOST_PROBE_SNAT_IP | "169.254.7.127" | Applied to SNAT host probe packets, so they can be identified/skipped podside. Any link-local address in the 169.254.0.0/16 block can be used |
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  4. 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)
  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