- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for runOnce (0.1 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/options/authentication_dynamic_request_header.go
RequestHeaderAuthRequestController: requestHeaderAuthRequestController, }, nil } func (c *DynamicRequestHeaderController) RunOnce(ctx context.Context) error { errs := []error{} errs = append(errs, c.ConfigMapCAController.RunOnce(ctx)) errs = append(errs, c.RequestHeaderAuthRequestController.RunOnce(ctx)) return errors.NewAggregate(errs) } func (c *DynamicRequestHeaderController) Run(ctx context.Context, workers int) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 07 14:37:01 UTC 2022 - 2.8K 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) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/union_content.go
curr.AddListener(listener) } } // AddListener adds a listener to be notified when the CA content changes. func (c unionCAContent) RunOnce(ctx context.Context) error { errors := []error{} for _, curr := range c { if controller, ok := curr.(ControllerRunner); ok { if err := controller.RunOnce(ctx); err != nil { errors = append(errors, err) } } } return utilerrors.NewAggregate(errors) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 07 14:37:01 UTC 2022 - 3.1K bytes - Viewed (0) -
src/go/printer/testdata/alignment.golden
MinimumGCAge: s.MinimumGCAge, MaxPerPodContainerCount: s.MaxPerPodContainerCount, MaxContainerCount: s.MaxContainerCount, ClusterDomain: s.ClusterDomain, ClusterDNS: s.ClusterDNS, Runonce: s.RunOnce, Port: s.Port, ReadOnlyPort: s.ReadOnlyPort, CadvisorInterface: cadvisorInterface, EnableServer: s.EnableServer, EnableDebuggingHandlers: s.EnableDebuggingHandlers,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 14 20:40:15 UTC 2018 - 4.1K bytes - Viewed (0) -
src/go/printer/testdata/alignment.input
MaxContainerCount: s.MaxContainerCount, ClusterDomain: s.ClusterDomain, ClusterDNS: s.ClusterDNS, Runonce: s.RunOnce, Port: s.Port, ReadOnlyPort: s.ReadOnlyPort, CadvisorInterface: cadvisorInterface, EnableServer: s.EnableServer,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 14 20:40:15 UTC 2018 - 4.9K 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)