- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 44 for runOnce (0.27 sec)
-
staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go
return } // doesn't matter what workers say, only start one. go wait.Until(c.runWorker, time.Second, ctx.Done()) <-ctx.Done() } // // RunOnce runs a single sync loop func (c *RequestHeaderAuthRequestController) RunOnce(ctx context.Context) error { configMap, err := c.client.CoreV1().ConfigMaps(c.configmapNamespace).Get(ctx, c.configmapName, metav1.GetOptions{}) switch { case errors.IsNotFound(err):
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.9K bytes - Viewed (0) -
tensorflow/cc/saved_model/loader.cc
// session dies. With this Callable mechanism, that memory will be released // right after ReleaseCallable returns. // // However, the resource manager state remains. Status RunOnce(const RunOptions& run_options, const std::vector<std::pair<string, Tensor>>& inputs, const std::vector<string>& output_tensor_names, const std::vector<string>& target_node_names,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Apr 02 04:36:00 UTC 2024 - 23K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/authentication.go
// We are passing the context to ProxyCerts.RunOnce as it needs to implement RunOnce(ctx) however the // context is not used at all. So passing a empty context shouldn't be a problem ctx := context.TODO() if err := dynamicRequestHeaderProvider.RunOnce(ctx); err != nil { return nil, err } return &authenticatorfactory.RequestHeaderConfig{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 21 14:51:22 UTC 2023 - 19.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
tcpConnectsInFlight += plan val taskName = "$okHttpName connect ${routePlanner.address.url.redact()}" taskRunner.newQueue().schedule( object : Task(taskName) { override fun runOnce(): Long { val connectResult = try { plan.connectTcp() } catch (e: Throwable) { ConnectResult(plan, throwable = e) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
private val cleanupTask = object : Task("$okHttpName ConnectionPool connection closer") { override fun runOnce(): Long = closeConnections(System.nanoTime()) } private fun AddressState.scheduleOpener() { queue.schedule( object : Task("$okHttpName ConnectionPool connection opener") { override fun runOnce(): Long = openConnections(this@scheduleOpener) }, ) } /**
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 16.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/server_test.go
&nullCAContent{name: "client-ca"}, defaultCertProvider, sniCerts, nil, // TODO see how to plumb an event recorder down in here. For now this results in simply klog messages. ) if err := dynamicCertificateController.RunOnce(); err != nil { t.Fatal(err) } tlsConfig.GetConfigForClient = dynamicCertificateController.GetConfigForClient
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 12 18:29:15 UTC 2021 - 6K bytes - Viewed (0) -
cmd/kubelet/app/server.go
klog.ErrorS(err, "Failed to set rlimit on max file handles") } // process pods and exit. if runOnce { if _, err := k.RunOnce(podCfg.Updates()); err != nil { return fmt.Errorf("runonce failed: %w", err) } klog.InfoS("Started kubelet as runonce") } else { startKubelet(k, podCfg, &kubeServer.KubeletConfiguration, kubeDeps, kubeServer.EnableServer) klog.InfoS("Started kubelet")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0) -
pkg/kubelet/apis/config/v1beta1/zz_generated.conversion.go
return err } if err := v1.Convert_Pointer_string_To_string(&in.ResolverConfig, &out.ResolverConfig, s); err != nil { return err } out.RunOnce = in.RunOnce if err := v1.Convert_Pointer_bool_To_bool(&in.CPUCFSQuota, &out.CPUCFSQuota, s); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 17:55:59 UTC 2024 - 48.9K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
go wait.Until(r.ipWorker, r.workerLoopPeriod, stopCh) go wait.Until(r.svcWorker, r.workerLoopPeriod, stopCh) } <-stopCh } // runOnce verifies the state of the ClusterIP allocations and returns an error if an unrecoverable problem occurs. func (r *RepairIPAddress) runOnce() error { return retry.RetryOnConflict(retry.DefaultBackoff, r.doRunOnce) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller_test.go
// test data target := newDefaultTarget() fakeKubeClient := fake.NewSimpleClientset(scenario.cm) target.client = fakeKubeClient // act ctx := context.TODO() err := target.RunOnce(ctx) if err != nil && !scenario.expectErr { t.Errorf("got unexpected error %v", err) } if err == nil && scenario.expectErr { t.Error("expected an error but didn't get one") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 07 14:37:01 UTC 2022 - 9.3K bytes - Viewed (0)