- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 390 for Informer (0.21 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source_test.go
defer testCancel() require.NoError(t, testContext.Start()) // Should be able to wait for cache sync require.True(t, cache.WaitForCacheSync(testContext.Done(), testContext.Source.HasSynced), "cache should sync after informer running") } func TestPolicySourceHasSyncedInitialList(t *testing.T) { // Create a list of fake policies initialObjects := []runtime.Object{ &FakePolicy{ ObjectMeta: metav1.ObjectMeta{ Name: "policy1",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/kube/kubetypes/types.go
// If unset, a default transform is provided to remove ManagedFields (high cost, low value) ObjectTransform func(obj any) (any, error) // InformerType dictates the type of informer that should be created. InformerType InformerType } type InformerType int const ( StandardInformer InformerType = iota DynamicInformer MetadataInformer )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/util/util.go
return volumeSpec, nil } // Do not return the original volume object, since it's from the shared // informer it may be mutated by another consumer. clonedPodVolume := podVolume.DeepCopy() origspec := volume.NewSpecFromVolume(clonedPodVolume)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 12K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
jobListerSynced: jobInformer.Informer().HasSynced, cronJobListerSynced: cronJobsInformer.Informer().HasSynced, now: time.Now, } jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: jm.addJob, UpdateFunc: jm.updateJob, DeleteFunc: jm.deleteJob, }) cronJobsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
// registerHandlers registers a handler for a given informer // Note: `otype` is used for metric, if empty, no metric will be reported func registerHandlers[T controllers.ComparableObject](c *Controller, informer kclient.Informer[T], otype string, handler func(T, T, model.Event) error, filter FilterOutFunc[T], ) { wrappedHandler := func(prev, curr T, event model.Event) error { curr = informer.Get(curr.GetName(), curr.GetNamespace())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
func NewClusterAuthenticationTrustController(requiredAuthenticationData ClusterAuthenticationInfo, kubeClient kubernetes.Interface) *Controller { // we construct our own informer because we need such a small subset of the information available. Just one namespace.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/controlplane/controller/defaultservicecidr/default_servicecidr_controller.go
c.cidrs = append(c.cidrs, primaryRange.String()) if secondaryRange.IP != nil { c.cidrs = append(c.cidrs, secondaryRange.String()) } // instead of using the shared informers from the controlplane instance, we construct our own informer // because we need such a small subset of the information available, only the kubernetes.default ServiceCIDR
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2_test.go
} client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc()) _ = informerFactory.Batch().V1().CronJobs().Informer().GetIndexer().Add(tt.cronJob) for _, job := range tt.finishedJobs { _ = informerFactory.Batch().V1().Jobs().Informer().GetIndexer().Add(job) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 70.8K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
monitor monitor.Monitor // hpaLister is able to list/get HPAs from the shared cache from the informer passed in to // NewHorizontalController. hpaLister autoscalinglisters.HorizontalPodAutoscalerLister hpaListerSynced cache.InformerSynced // podLister is able to list/get Pods from the shared cache from the informer passed in to // NewHorizontalController. podLister corelisters.PodLister
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/admission.go
c *server.Config, informers informers.SharedInformerFactory, kubeClient kubernetes.Interface, dynamicClient dynamic.Interface, features featuregate.FeatureGate, pluginInitializers ...admission.PluginInitializer, ) error { if a == nil { return nil } // Admission depends on CoreAPI to set SharedInformerFactory and ClientConfig. if informers == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 12 08:49:42 UTC 2024 - 9.7K bytes - Viewed (0)