Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for Nick (0.12 sec)

  1. cni/test/install_cni.go

    	}
    	if !chainedCNIPlugin {
    		installConfig.InstallConfig.ChainedCNIPlugin = false
    	}
    
    	startInstallServer(ctx, &installConfig, t)
    }
    
    // checkResult checks if resultFile is equal to expectedFile at each tick until timeout
    func checkResult(result, expected string) error {
    	resultFile, err := os.ReadFile(result)
    	if err != nil {
    		return fmt.Errorf("couldn't read result: %v", err)
    	}
    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)
  2. cni/pkg/install/install_test.go

    			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:
    						if isReady.Load().(bool) {
    							readyChan <- true
    						}
    					}
    				}
    			}(ctx, ticker.C)
    
    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/ipset/ipset.go

    // TODO this should actually create v6 and v6 subsets of type `hash:ip`, add them both to a
    // superset of type `list:set` - we can then query the superset directly in iptables (with the same rule),
    // and iptables will be smart enough to pick the correct underlying set (v4 or v6, based on context),
    // reducing the # of rules we need.
    //
    // BUT netlink lib doesn't support adding things to `list:set` types yet, and current tagged release
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  4. istioctl/pkg/wait/wait.go

    				select {
    				case newVersion := <-w.resultsChan:
    					printVerbosef(cmd, "received new target version: %s", newVersion)
    					generations = append(generations, newVersion)
    				case <-t.C:
    					printVerbosef(cmd, "tick")
    					continue
    				case err = <-w.errorChan:
    					t.Stop()
    					return fmt.Errorf("unable to retrieve Kubernetes resource2 %s: %v", "", err)
    				case <-ctx.Done():
    					printVerbosef(cmd, "timeout")
    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)
Back to top