- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,086 for Reflector (0.24 sec)
-
pkg/kubelet/util/manager/watch_based_manager.go
// objectCacheItem is a single item stored in objectCache. type objectCacheItem struct { refMap map[types.UID]int store *cacheStore reflector *cache.Reflector hasSynced func() (bool, error) // waitGroup is used to ensure that there won't be two concurrent calls to reflector.Run waitGroup sync.WaitGroup // lock is to ensure the access and modify of lastAccessTime, stopped, and immutable are thread safety,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager_test.go
assert.True(t, reflectorRunning()) fakeClock.Step(90 * time.Second) store.startRecycleIdleWatch() // Reflector should already be stopped for maxIdleTime exceeded. assert.False(t, reflectorRunning()) obj, _ = store.Get("ns", "name") assert.True(t, apiequality.Semantic.DeepEqual(secret, obj)) // Reflector should reRun after get secret again. assert.True(t, reflectorRunning()) fakeClock.Step(20 * time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 09 10:05:43 UTC 2023 - 17.2K bytes - Viewed (0) -
pkg/kubelet/config/apiserver.go
lw := cache.NewListWatchFromClient(c.CoreV1().RESTClient(), "pods", metav1.NamespaceAll, fields.OneTermEqualSelector("spec.nodeName", string(nodeName))) // The Reflector responsible for watching pods at the apiserver should be run only after // the node sync with the apiserver has completed. klog.InfoS("Waiting for node sync before watching apiserver pods") go func() { for {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 21 19:46:27 UTC 2021 - 2.4K bytes - Viewed (0) -
pilot/pkg/util/informermetric/informerutil.go
handler, ok := handlers[clusterID] mu.RUnlock() if ok { return handler } mu.Lock() defer mu.Unlock() clusterMetric := errorMetric.With(clusterLabel.Value(clusterID.String())) h := func(_ *cache.Reflector, err error) { clusterMetric.Increment() log.Errorf("watch error in cluster %s: %v", clusterID, err) } handlers[clusterID] = h return h
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 1.6K bytes - Viewed (0) -
pkg/scheduler/internal/cache/interface.go
// Cache's operations are pod centric. It does incremental updates based on pod events. // Pod events are sent via network. We don't have guaranteed delivery of all events: // We use Reflector to list and watch from remote. // Reflector might be slow and do a relist, which would lead to missing events. // // State Machine of a pod's events in scheduler's cache: // // +-------------------------------------------+ +----+
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// In most of the cases, leader is reelected within few cycles. reflector.MaxInternalErrorRetryDuration = time.Second * 30 // since the watch-list is provided by the watch cache instruct // the reflector to issue a regular LIST against the store reflector.UseWatchList = ptr.To(false) cacher.watchCache = watchCache cacher.reflector = reflector go cacher.dispatchEvents() go progressRequester.Run(stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/naming/from_stack.go
"strconv" "strings" ) // GetNameFromCallsite walks back through the call stack until we find a caller from outside of the ignoredPackages // it returns back a shortpath/filename:line to aid in identification of this reflector when it starts logging func GetNameFromCallsite(ignoredPackages ...string) string { name := "????" const maxStack = 10 for i := 1; i < maxStack; i++ { _, file, line, ok := goruntime.Caller(i) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 12 01:31:42 UTC 2019 - 2.6K bytes - Viewed (0) -
pkg/volume/util/recyclerclient/recycler_client.go
DeletePod(name, namespace string) error // WatchPod returns a ListWatch for watching a pod. The stopChannel is used // to close the reflector backing the watch. The caller is responsible for // derring a close on the channel to stop the reflector. WatchPod(name, namespace string, stopChannel chan struct{}) (<-chan watch.Event, error) // Event sends an event to the volume that is being recycled.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 8.5K bytes - Viewed (1) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/resources.go
// can get a different RV because etcd can be touched in between the initial list operation (if that's what you're doing first) // and the storage cache reflector starting. // Later, you can issue a watch with the REST apis list.RV and end up earlier than the storage cacher. // The general working model is that if you get a "resourceVersion too old" message, you re-list and rewatch.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 19 02:01:40 UTC 2021 - 21.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
// maxWatchChanSizeWithIndexAndTriger is the max size of the channel // used by the watch using the index and trigger selector. maxWatchChanSizeWithIndexAndTrigger = 10 // maxWatchChanSizeWithIndexWithoutTrigger is the max size of the channel // used by the watch using the index but without triggering selector. // We keep that set to 1000 for "backward compatibility", until we
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0)