- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 71 for syncAt (0.38 sec)
-
pkg/kube/krt/informer.go
var _ internalCollection[controllers.Object] = &informer[controllers.Object]{} func (i *informer[I]) _internalHandler() {} func (i *informer[I]) Synced() Syncer { return channelSyncer{ name: i.collectionName, synced: i.synced, } } // nolint: unused // (not true, its to implement an interface) func (i *informer[I]) dump() { i.log.Errorf(">>> BEGIN DUMP") for _, obj := range i.inf.List(metav1.NamespaceAll, klabels.Everything()) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 11:01:46 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// - plegCh: update the runtime cache; sync pod // - syncCh: sync all pods waiting for sync // - housekeepingCh: trigger cleanup of pods // - health manager: sync pods that have failed or in which one or more // containers have failed health checks func (kl *Kubelet) syncLoopIteration(ctx context.Context, configCh <-chan kubetypes.PodUpdate, handler SyncHandler,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
// services that happened since nftables was synced. For a single object, // changes are accumulated, i.e. previous is state from before all of them, // current is state after applying all of those. endpointsChanges *proxy.EndpointsChangeTracker serviceChanges *proxy.ServiceChangeTracker mu sync.Mutex // protects the following fields svcPortMap proxy.ServicePortMap
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pkg/kube/namespace/filter.go
d.discoveryNamespaces.Delete(ns.Name) } // AddHandler registers a handler on namespace, which will be triggered when namespace selected or deselected. // If the namespaces have been synced, trigger the new added handler. func (d *discoveryNamespacesFilter) AddHandler(f func(added, removed sets.String)) { d.lock.Lock() defer d.lock.Unlock() d.handlers = append(d.handlers, f) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 9.3K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
uid := types.UID("1") if len(w.podSyncStatuses) != 0 { t.Fatalf("unexpected sync statuses: %#v", w.podSyncStatuses) } // no pod sync record was delivered if actual, expected := records[uid], []syncPodRecord(nil); !reflect.DeepEqual(expected, actual) { t.Fatalf("unexpected pod sync records: %s", cmp.Diff(expected, actual, cmp.AllowUnexported(syncPodRecord{}))) } },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
syncHandler func(ctx context.Context, jobKey string) error // podStoreSynced returns true if the pod store has been synced at least once. // Added as a member to the struct to allow injection for testing. podStoreSynced cache.InformerSynced // jobStoreSynced returns true if the job store has been synced at least once. // Added as a member to the struct to allow injection for testing. jobStoreSynced cache.InformerSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
} func (s *Server) waitForCacheSync(stop <-chan struct{}) bool { start := time.Now() log.Info("Waiting for caches to be synced") if !kubelib.WaitForCacheSync("server", stop, s.cachesSynced) { log.Errorf("Failed waiting for cache sync") return false } log.Infof("All controller caches have been synced up in %v", time.Since(start)) // At this point, we know that all update events of the initial state-of-the-world have been
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
src/sync/waitgroup.go
// Copyright 2011 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package sync import ( "internal/race" "sync/atomic" "unsafe" ) // A WaitGroup waits for a collection of goroutines to finish. // The main goroutine calls [WaitGroup.Add] to set the number of // goroutines to wait for. Then each of the goroutines
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4K bytes - Viewed (0) -
platforms/core-configuration/file-collections/src/integTest/groovy/org/gradle/api/file/FileCollectionIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 12:54:09 UTC 2024 - 21K bytes - Viewed (0) -
src/sync/mutex.go
// Package sync provides basic synchronization primitives such as mutual // exclusion locks. Other than the [Once] and [WaitGroup] types, most are intended // for use by low-level library routines. Higher-level synchronization is // better done via channels and communication. // // Values containing the types defined in this package should not be copied. package sync import ( "internal/race" "sync/atomic"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0)