- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewTicker (0.22 sec)
-
cni/pkg/install/install_test.go
if err := file.AtomicCopy(filepath.Join("testdata", c.validConfigFilename), tempDir, c.cniConfigFilename); err != nil { 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
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) -
istioctl/pkg/waypoint/waypoint.go
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) -
istioctl/pkg/wait/wait.go
w = withContext(ctx) w.Go(func(result chan string) error { result <- generation return nil }) } // wait for all deployed versions to be contained in generations t := time.NewTicker(pollInterval) printVerbosef(cmd, "getting first version from chan") firstVersion, err := w.BlockingRead() if err != nil { return fmt.Errorf("unable to retrieve Kubernetes resource %s: %v", "", err) }
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)