- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 985 for waits (0.1 sec)
-
pkg/proxy/config/config.go
func (c *EndpointSliceConfig) RegisterEventHandler(handler EndpointSliceHandler) { c.eventHandlers = append(c.eventHandlers, handler) } // Run waits for cache synced and invokes handlers after syncing. func (c *EndpointSliceConfig) Run(stopCh <-chan struct{}) { c.logger.Info("Starting endpoint slice config controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/deployment/internal/DefaultDeploymentRegistryTest.groovy
when: registry.stop() then: 1 * pendingChangesManager.removeListener(_) } def "can start a deployment with a given type and parameters and continuous build waits"() { def testHandle = new ParametersDeploymentHandle("parameter") objectFactory.newInstance(ParametersDeploymentHandle, "parameter") >> testHandle when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 13:46:07 UTC 2024 - 4.6K bytes - Viewed (0) -
src/runtime/cgo/libcgo.h
*/ extern uintptr_t *_cgo_pthread_key_created; /* * Creates the new operating system thread (OS, arch dependent). */ void _cgo_sys_thread_start(ThreadStart *ts); /* * Waits for the Go runtime to be initialized (OS dependent). * If runtime.SetCgoTraceback is used to set a context function, * calls the context function and returns the context value. */ uintptr_t _cgo_wait_runtime_init_done(void);
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 13 20:50:04 UTC 2024 - 3.5K bytes - Viewed (0) -
pkg/kube/multicluster/cluster.go
Update ) func (a ACTION) String() string { switch a { case Add: return "Add" case Update: return "Update" } return "Unknown" } // Run starts the cluster's informers and waits for caches to sync. Once caches are synced, we mark the cluster synced. // This should be called after each of the handlers have registered informers, and should be run in a goroutine.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.8K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServer.java
*/ void releaseAll(); /** * Waits for the expected number of concurrent requests to be received. */ void waitForAllPendingCalls(); /** * Waits for the expected number of concurrent requests to be received or until the given {@link FailureTracker} provides a
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 21.7K bytes - Viewed (0) -
cni/pkg/util/pluginutil.go
"istio.io/istio/pkg/log" ) type Watcher struct { watcher *fsnotify.Watcher Events chan struct{} Errors chan error } // Waits until a file is modified (returns nil), the context is cancelled (returns context error), or returns error func (w *Watcher) Wait(ctx context.Context) error { select { case <-w.Events: return nil case err := <-w.Errors: return err case <-ctx.Done(): return ctx.Err()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 3.6K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
) const ( // reconcilerLoopSleepPeriod is the amount of time the reconciler loop waits // between successive executions reconcilerLoopSleepPeriod = 100 * time.Millisecond // desiredStateOfWorldPopulatorLoopSleepPeriod is the amount of time the // DesiredStateOfWorldPopulator loop waits between successive executions desiredStateOfWorldPopulatorLoopSleepPeriod = 100 * time.Millisecond
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
const pollInterval = time.Second // Cmd represents the wait command func Cmd(cliCtx cli.Context) *cobra.Command { namespace := cliCtx.Namespace() var opts clioptions.ControlPlaneOptions cmd := &cobra.Command{ Use: "wait [flags] <type> <name>[.<namespace>]", Short: "Wait for an Istio resource", Long: `Waits for the specified condition to be true of an Istio resource.`,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 17 12:24:17 UTC 2024 - 10.1K bytes - Viewed (1) -
src/net/http/main_test.go
// shutting down, so give it some time. time.Sleep(1 * time.Millisecond) } t.Errorf("Test appears to have leaked %s:\n%s", bad, stacks) } // waitCondition waits for fn to return true, // checking immediately and then at exponentially increasing intervals. func waitCondition(t testing.TB, delay time.Duration, fn func(time.Duration) bool) { t.Helper() start := time.Now()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 03 22:49:46 UTC 2024 - 4.9K bytes - Viewed (0) -
pkg/kube/client.go
ObjectFilter() kubetypes.DynamicObjectFilter // RunAndWait starts all informers and waits for their caches to sync. // Warning: this must be called AFTER .Informer() is called, which will register the informer. // "false" is returned if this prematurely exited without syncing. RunAndWait(stop <-chan struct{}) bool // WaitForCacheSync waits for all cache functions to sync, as well as all informers started by the *fake* client.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0)