- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 39 for Informer (0.87 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
} func (c *Cacher) dispatchEvents() { // Jitter to help level out any aggregate load. bookmarkTimer := c.clock.NewTimer(wait.Jitter(time.Second, 0.25)) defer bookmarkTimer.Stop() // The internal informer populates the RV as soon as it conducts // The first successful sync with the underlying store. // The cache must wait until this first sync is completed to be deemed ready.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
plugin/pkg/admission/limitranger/admission_test.go
return true, limitRangeList, nil }) return mockClient } // newHandlerForTest returns a handler configured for testing. func newHandlerForTest(c clientset.Interface) (*LimitRanger, informers.SharedInformerFactory, error) { f := informers.NewSharedInformerFactory(c, 5*time.Minute) handler, err := NewLimitRanger(&DefaultLimitRangerActions{}) if err != nil { return nil, f, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 51.5K bytes - Viewed (0) -
src/index/suffixarray/sais2.go
// Because j-1 is type L, inserting it into sa now will sort it correctly. // But we want to distinguish a j-1 with j-2 of type L from type S. // We can process the former but want to leave the latter for the caller. // We record the difference by negating j-1 if it is preceded by type S. // Either way, the insertion (into the text[j-1] bucket) is guaranteed to
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 18 23:57:18 UTC 2024 - 52.3K bytes - Viewed (0) -
cluster/gce/windows/k8s-node-setup.psm1
# namespace name, 'synth-lgr' is the container name and '997599971ee6..' is # the container ID. # The record reformer is used to extract pod_name, namespace_name and # container_name from the tag and set them in a local_resource_id in the # format of: # 'k8s_container.<NAMESPACE_NAME>.<POD_NAME>.<CONTAINER_NAME>'. # The reformer also changes the tags to 'stderr' or 'stdout' based on the # value of 'stream'.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 88.3K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
"time" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/wait" utilfeature "k8s.io/apiserver/pkg/util/feature" "k8s.io/client-go/informers" listersv1 "k8s.io/client-go/listers/core/v1" "k8s.io/client-go/tools/cache" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/features" "k8s.io/kubernetes/pkg/scheduler/framework"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
tensorflow/BUILD
define_values = {"no_tensorflow_py_deps": "true"}, visibility = ["//visibility:public"], ) # Sometimes Bazel reports darwin_x86_64 as "darwin" and sometimes as # "darwin_x86_64". The former shows up when building on a Mac x86_64 host for a Mac x86_64 target. # The latter shows up when cross-compiling for Mac x86_64 from a Mac ARM machine and in internal # Google builds. config_setting(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 31 16:51:59 UTC 2024 - 53.5K bytes - Viewed (0) -
src/runtime/mgcscavenge.go
// fragmentation and reduce the RSS of Go applications. // // Scavenging in Go happens on two fronts: there's the background // (asynchronous) scavenger and the allocation-time (synchronous) scavenger. // // The former happens on a goroutine much like the background sweeper which is // soft-capped at using scavengePercent of the mutator's time, based on // order-of-magnitude estimates of the costs of scavenging. The latter happens
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:48:45 UTC 2024 - 52.3K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/optimizing-performance/configuration_cache.adoc
Another example involves providing additional guidance for your users, should they need to adjust their setup or be informed of temporary limitations. [[config_cache:adoption:changes_in_behavior]] === Adopting changes in the configuration cache behavior
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 29 16:24:12 UTC 2024 - 71.1K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
// to remove the pod. A terminal pod (Succeeded/Failed) will have // termination status until the pod is deleted. finished bool // restartRequested is true if the pod worker was informed the pod is // expected to exist (update type of create, update, or sync) after // it has been killed. When known pods are synced, any pod that is // terminated and has restartRequested will have its history cleared.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
// Update healthz timestamp at beginning in case Sync() never succeeds. if proxier.healthzServer != nil { proxier.healthzServer.Updated(proxier.ipFamily) } // synthesize "last change queued" time as the informers are syncing. metrics.SyncProxyRulesLastQueuedTimestamp.SetToCurrentTime() proxier.syncRunner.Loop(wait.NeverStop) } func (proxier *Proxier) setInitialized(value bool) { var initialized int32 if value {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0)