- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 851 for syncAt (0.09 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/apiapproval/apiapproval_controller.go
// To allow injection for testing. syncFn func(key string) error queue workqueue.TypedRateLimitingInterface[string] // last protectedAnnotation value this controller updated the condition per CRD name (to avoid two // different version of the apiextensions-apiservers in HA to fight for the right message) lastSeenProtectedAnnotationLock sync.Mutex lastSeenProtectedAnnotation map[string]string }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
} if !podWorkers.CouldHaveRunningContainers(types.UID("abc")) { t.Errorf("Expected pod to potentially have running containers (does not exist but not yet synced)") } if podWorkers.ShouldPodContentBeRemoved(types.UID("abc")) { t.Errorf("Expected pod to not be suitable for removal (does not exist but not yet synced)") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
return false } // Check all config cluster components are synced // c.ConfigClusterHandler.HasSynced does not work; config cluster is handle specially if !kube.AllSynced(c.configClusterSyncers) { return false } // Check all remote clusters are synced (or timed out) return c.cs.HasSynced() } func (c *Controller) processItem(key types.NamespacedName) error { log.Infof("processing secret event for secret %s", key)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go
crdsSynced cache.InformerSynced // To allow injection for testing. syncFn func(string) error queue workqueue.TypedRateLimitingInterface[string] staticSpec *spec.Swagger openAPIService *handler.OpenAPIService // specs by name. The specs are lazily constructed on request. // The lock is for the map only. lock sync.Mutex specsByName map[string]*specCache }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go
AddFunc: c.addCustomResourceDefinition, UpdateFunc: c.updateCustomResourceDefinition, DeleteFunc: c.deleteCustomResourceDefinition, }) c.syncFn = c.sync return c } func (c *DiscoveryController) sync(version schema.GroupVersion) error { apiVersionsForDiscovery := []metav1.GroupVersionForDiscovery{} apiResourcesForDiscovery := []metav1.APIResource{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 21 11:40:03 UTC 2024 - 12.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go
crdSynced cache.InformerSynced // To allow injection for testing. syncFn func(key string) error queue workqueue.TypedRateLimitingInterface[string] // last generation this controller updated the condition per CRD name (to avoid two // different version of the apiextensions-apiservers in HA to fight for the right message) lastSeenGenerationLock sync.Mutex lastSeenGeneration map[string]int64 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go
crdLister listers.CustomResourceDefinitionLister crdsSynced cache.InformerSynced // To allow injection for testing. syncFn func(string) error queue workqueue.TypedRateLimitingInterface[string] openAPIV3Service *handler3.OpenAPIService // specs per version and per CRD name lock sync.Mutex specsByGVandName map[schema.GroupVersion]map[string]*spec3.OpenAPI }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.9K bytes - Viewed (0) -
CONTRIBUTING.md
Due to Guava's nature as a subset of Google's internal codebase which is automatically synced to the public GitHub repository, we are unable to merge pull requests directly into the master branch. Instead, once a pull request is ready for merging, we'll make the appropriate changes in the internal codebase and, when the change is synced out, give the pull request author credit for the commit. Contributor License Agreement
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Nov 17 18:47:47 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/proxy/config/config_test.go
delete(h.state, namespacedName) h.sendServices() } func (h *ServiceHandlerMock) OnServiceSynced() { h.lock.Lock() defer h.lock.Unlock() h.synced = true h.sendServices() } func (h *ServiceHandlerMock) sendServices() { if !h.synced { return } services := make([]*v1.Service, 0, len(h.state)) for _, svc := range h.state { services = append(services, svc) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/proxy/node.go
// OnNodeDelete is a handler for Node deletes. func (n *NodePodCIDRHandler) OnNodeDelete(node *v1.Node) { n.logger.Error(nil, "Current Node is being deleted", "node", klog.KObj(node)) } // OnNodeSynced is a handler for Node syncs. func (n *NodePodCIDRHandler) OnNodeSynced() {} // NodeEligibleHandler handles the life cycle of the Node's eligibility, as // determined by the health server for directing load balancer traffic.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 3.5K bytes - Viewed (0)