Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for Dickert (0.26 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 01 22:53:12 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 01 22:53:12 GMT 2024
    - Last Modified: Wed May 01 16:16:40 GMT 2024
    - 15.2K bytes
    - Viewed (0)
  3. 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 01 22:53:12 GMT 2024
    - Last Modified: Sat Feb 17 12:24:17 GMT 2024
    - 10.1K bytes
    - Viewed (0)
Back to top