- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for runOnce (0.22 sec)
-
pkg/kubelet/runonce.go
result, err := kl.runOnce(ctx, u.Pods, runOnceRetryDelay) klog.InfoS("Finished processing pods", "numPods", len(u.Pods)) return result, err case <-time.After(runOnceManifestDelay): return nil, fmt.Errorf("no pod manifest update after %v", runOnceManifestDelay) } } // runOnce runs a given set of pods and returns their status.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 5.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/secure_serving.go
} }() // start controllers if possible if controller, ok := s.ClientCA.(dynamiccertificates.ControllerRunner); ok { // runonce to try to prime data. If this fails, it's ok because we fail closed. // Files are required to be populated already, so this is for convenience. if err := controller.RunOnce(ctx); err != nil { klog.Warningf("Initial population of client CA failed: %v", err) } go controller.Run(ctx, 1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 10.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(750)) { log.put("runOnce delays.size=${delays.size}") return@schedule delays.removeAt(0) } assertThat(log.take()).isEqualTo("runOnce delays.size=2") val t2 = System.nanoTime() / 1e6 - t1 assertThat(t2).isCloseTo(750.0, 250.0) assertThat(log.take()).isEqualTo("runOnce delays.size=1") val t3 = System.nanoTime() / 1e6 - t1
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.5K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repair_test.go
item: &api.RangeAllocation{Range: "192.168.1.0/24"}, } _, cidr, _ := netutils.ParseCIDRSloppy(ipregistry.item.Range) r := NewRepair(0, fakeClient.CoreV1(), fakeClient.EventsV1(), cidr, ipregistry, nil, nil) if err := r.runOnce(); err != nil { t.Fatal(err) } if !ipregistry.updateCalled || ipregistry.updated == nil || ipregistry.updated.Range != cidr.String() || ipregistry.updated != ipregistry.item {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 21.1K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/controller/repair_test.go
if err := r.runOnce(); err != nil { t.Fatal(err) } after, err := portallocator.NewFromSnapshot(registry.updated) if err != nil { t.Fatal(err) } if !after.Has(111) { t.Errorf("expected portallocator to still have leaked port") } } // Run one more time to actually remove the leak. if err := r.runOnce(); err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 10.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/Task.kt
*/ package okhttp3.internal.concurrent /** * A unit of work that can be executed one or more times. * * Recurrence * ---------- * * Tasks control their recurrence schedule. The [runOnce] function returns -1L to signify that the * task should not be executed again. Otherwise it returns a delay until the next execution. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_cafile_content.go
var FileRefreshDuration = 1 * time.Minute // ControllerRunner is a generic interface for starting a controller type ControllerRunner interface { // RunOnce runs the sync loop a single time. This useful for synchronous priming RunOnce(ctx context.Context) error // Run should be called a go .Run Run(ctx context.Context, workers int) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
val task = object : Task("task") { val schedules = mutableListOf(50.µs) val delays = mutableListOf(200.µs, -1) override fun runOnce(): Long { log += "run@${taskFaker.nanoTime}" if (schedules.isNotEmpty()) { redQueue.schedule(this, schedules.removeAt(0)) } return delays.removeAt(0) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 23K bytes - Viewed (0) -
pkg/controlplane/apiserver/server.go
s.ClusterAuthenticationInfo.ClientCA.AddListener(controller) if controller, ok := s.ClusterAuthenticationInfo.ClientCA.(dynamiccertificates.ControllerRunner); ok { // runonce to be sure that we have a value. if err := controller.RunOnce(ctx); err != nil { runtime.HandleError(err) } go controller.Run(ctx, 1) } } if s.ClusterAuthenticationInfo.RequestHeaderCA != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 19:24:41 UTC 2024 - 11K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.5K bytes - Viewed (0)