- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 46 for NewSharedInformerFactory (0.76 sec)
-
pkg/controller/resourceclaim/controller_test.go
return true, nil, apierrors.NewConflict(action.GetResource().GroupResource(), "fake name", errors.New("fake conflict")) }) } setupMetrics() informerFactory := informers.NewSharedInformerFactory(fakeKubeClient, controller.NoResyncPeriodFunc()) podInformer := informerFactory.Core().V1().Pods() podSchedulingInformer := informerFactory.Resource().V1alpha2().PodSchedulingContexts()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 08:56:16 UTC 2024 - 28.2K bytes - Viewed (0) -
pkg/kube/client.go
clusterID: "fake", } c.kube = fake.NewSimpleClientset(objects...) c.config = &rest.Config{ Host: "server", } c.informerFactory = informerfactory.NewSharedInformerFactory() s := FakeIstioScheme c.metadata = metadatafake.NewSimpleMetadataClient(s) c.dynamic = dynamicfake.NewSimpleDynamicClient(s) c.istio = istiofake.NewSimpleClientset()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0) -
pkg/scheduler/eventhandlers_test.go
for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { logger, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancel(ctx) defer cancel() informerFactory := informers.NewSharedInformerFactory(fake.NewSimpleClientset(), 0) schedulingQueue := queue.NewTestQueueWithInformerFactory(ctx, nil, informerFactory) testSched := Scheduler{ StopEverything: ctx.Done(), SchedulingQueue: schedulingQueue,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 10 14:38:54 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/controlplane/instance_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/ipallocator_test.go
api "k8s.io/kubernetes/pkg/apis/core" netutils "k8s.io/utils/net" ) func newTestAllocator(cidr *net.IPNet) (*Allocator, error) { client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, 0*time.Second) ipInformer := informerFactory.Networking().V1alpha1().IPAddresses() ipStore := ipInformer.Informer().GetIndexer()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jun 25 13:14:46 UTC 2023 - 24.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_test.go
config.OpenAPIV3Config = DefaultOpenAPIV3Config(testGetOpenAPIDefinitions, openapinamer.NewDefinitionNamer(runtime.NewScheme())) config.OpenAPIV3Config.Info.Version = "unversioned" sharedInformers := informers.NewSharedInformerFactory(clientset, config.LoopbackClientConfig.Timeout) config.Complete(sharedInformers) return *config, assert.New(t) } func newMaster(t *testing.T) (*GenericAPIServer, Config, *assert.Assertions) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 23.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go
t.Run(item.name, func(t *testing.T) { _, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancel(ctx) defer cancel() client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, 0) opts := []runtime.Option{ runtime.WithClientSet(client), runtime.WithInformerFactory(informerFactory), } fh, err := runtime.NewFramework(ctx, nil, nil, opts...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 32K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction_test.go
} var alwaysReady = func() bool { return true } func setupNewController(ctx context.Context, fakeClientSet *fake.Clientset) (*Controller, cache.Indexer, cache.Indexer) { informerFactory := informers.NewSharedInformerFactory(fakeClientSet, 0) podIndexer := informerFactory.Core().V1().Pods().Informer().GetIndexer() nodeIndexer := informerFactory.Core().V1().Nodes().Informer().GetIndexer()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller_test.go
func NewFromClient(ctx context.Context, kubeClient clientset.Interface, terminatedPodThreshold int) (*PodGCController, coreinformers.PodInformer, coreinformers.NodeInformer) { informerFactory := informers.NewSharedInformerFactory(kubeClient, controller.NoResyncPeriodFunc()) podInformer := informerFactory.Core().V1().Pods() nodeInformer := informerFactory.Core().V1().Nodes()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 08:16:48 UTC 2024 - 29K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler_test.go
testHandlerConversion(t, false) } func testHandlerConversion(t *testing.T, enableWatchCache bool) { cl := fake.NewSimpleClientset() informers := informers.NewSharedInformerFactory(fake.NewSimpleClientset(), 0) crdInformer := informers.Apiextensions().V1().CustomResourceDefinitions() server, storageConfig := etcd3testing.NewUnsecuredEtcd3TestClientServer(t) defer server.Terminate(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 13 15:27:39 UTC 2023 - 34.6K bytes - Viewed (0)