- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 39 for NewSharedInformerFactory (0.22 sec)
-
pkg/proxy/config/api_test.go
client.PrependWatchReactor("services", ktesting.DefaultWatchReactor(fakeWatch, nil)) stopCh := make(chan struct{}) defer close(stopCh) handler := NewServiceHandlerMock() sharedInformers := informers.NewSharedInformerFactory(client, time.Minute) serviceConfig := NewServiceConfig(ctx, sharedInformers.Core().V1().Services(), time.Minute) serviceConfig.RegisterEventHandler(handler) go sharedInformers.Start(stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 8.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/factory.go
return func(factory *sharedInformerFactory) *sharedInformerFactory { factory.transform = transform return factory } } // NewSharedInformerFactory constructs a new instance of sharedInformerFactory for all namespaces. func NewSharedInformerFactory(client versioned.Interface, defaultResync time.Duration) SharedInformerFactory { return NewSharedInformerFactoryWithOptions(client, defaultResync) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 18:31:26 UTC 2023 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/factory.go
return func(factory *sharedInformerFactory) *sharedInformerFactory { factory.transform = transform return factory } } // NewSharedInformerFactory constructs a new instance of sharedInformerFactory for all namespaces. func NewSharedInformerFactory(client clientset.Interface, defaultResync time.Duration) SharedInformerFactory { return NewSharedInformerFactoryWithOptions(client, defaultResync) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 18:31:26 UTC 2023 - 9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/testing.go
// populated with the provided objects. func NewTestQueueWithObjects( ctx context.Context, lessFn framework.LessFunc, objs []runtime.Object, opts ...Option, ) *PriorityQueue { informerFactory := informers.NewSharedInformerFactory(fake.NewSimpleClientset(objs...), 0) return NewTestQueueWithInformerFactory(ctx, lessFn, informerFactory, opts...) } func NewTestQueueWithInformerFactory( ctx context.Context, lessFn framework.LessFunc,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 10 00:53:58 UTC 2022 - 1.7K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator_test.go
) func TestFindAndAddActivePods_FindAndRemoveDeletedPods(t *testing.T) { fakeVolumePluginMgr, _ := volumetesting.GetTestVolumePluginMgr(t) fakeClient := &fake.Clientset{} fakeInformerFactory := informers.NewSharedInformerFactory(fakeClient, controller.NoResyncPeriodFunc()) fakePodInformer := fakeInformerFactory.Core().V1().Pods() fakesDSW := cache.NewDesiredStateOfWorld(fakeVolumePluginMgr) pod := &v1.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 7.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/resource_access_test.go
} for _, tc := range testcases { t.Run(tc.description, func(t *testing.T) { liveLookupCache := lru.New(1) kubeClient := fake.NewSimpleClientset(tc.clientInput...) informerFactory := informers.NewSharedInformerFactory(kubeClient, 0) accessor, _ := newQuotaAccessor() accessor.client = kubeClient accessor.lister = informerFactory.Core().V1().ResourceQuotas().Lister() accessor.liveLookupCache = liveLookupCache
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 13:54:56 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/controller/certificates/certificate_controller_test.go
csr := &certificates.CertificateSigningRequest{ ObjectMeta: metav1.ObjectMeta{ Name: "test-csr", }, } client := fake.NewSimpleClientset(csr) informerFactory := informers.NewSharedInformerFactory(fake.NewSimpleClientset(csr), controller.NoResyncPeriodFunc()) handler := func(ctx context.Context, csr *certificates.CertificateSigningRequest) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 15 03:26:08 UTC 2023 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/configuration/validating_webhook_manager_test.go
func TestGetValidatingWebhookConfig(t *testing.T) { // Build a test client that the admission plugin can use to look up the ValidatingWebhookConfiguration client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, 0) stop := make(chan struct{}) defer close(stop) manager := NewValidatingWebhookConfigurationManager(informerFactory) informerFactory.Start(stop) informerFactory.WaitForCacheSync(stop)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 15:20:14 UTC 2023 - 9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/testing/testing.go
sharedLister framework.SharedLister, objs []runtime.Object, ) framework.Plugin { objs = append([]runtime.Object{&v1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: ""}}}, objs...) informerFactory := informers.NewSharedInformerFactory(fake.NewSimpleClientset(objs...), 0) fh, err := frameworkruntime.NewFramework(ctx, nil, nil, frameworkruntime.WithSnapshotSharedLister(sharedLister), frameworkruntime.WithInformerFactory(informerFactory))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/coreapi.go
if err != nil { return fmt.Errorf("failed to create Kubernetes clientset: %v", err) } config.ClientConfig = kubeconfig config.SharedInformerFactory = clientgoinformers.NewSharedInformerFactory(clientgoExternalClient, 10*time.Minute) return nil } func (o *CoreAPIOptions) Validate() []error { return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 01 16:55:02 UTC 2022 - 2.7K bytes - Viewed (0)