- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 45 for newController (0.36 sec)
-
pkg/kubelet/images/image_gc_manager_test.go
Image: imageName(id), ImageID: imageID(id), } } func TestDetectImagesInitialDetect(t *testing.T) { ctx := context.Background() mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() mockStatsProvider := statstest.NewMockProvider(mockCtrl) manager, fakeRuntime := newRealImageGCManager(ImageGCPolicy{}, mockStatsProvider) fakeRuntime.ImageList = []container.Image{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 15:38:20 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller_test.go
} func newFixture(t testing.TB) *fixture { f := &fixture{} f.t = t f.objects = []runtime.Object{} return f } func (f *fixture) newController(ctx context.Context) (*DeploymentController, informers.SharedInformerFactory, error) { f.client = fake.NewSimpleClientset(f.objects...) informers := informers.NewSharedInformerFactory(f.client, controller.NoResyncPeriodFunc())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0) -
pilot/pkg/bootstrap/configcontroller.go
return err } } else if args.RegistryOptions.FileDir != "" { // Local files - should be added even if other options are specified store := memory.Make(collections.Pilot) configController := memory.NewController(store) err := s.makeFileMonitor(args.RegistryOptions.FileDir, args.RegistryOptions.KubeOptions.DomainSuffix, configController) if err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 14.1K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
checkHealthOrFail(t, store, p, false) }) } func setup(t *testing.T) (*Controller, *Controller, model.ConfigStoreController) { store := memory.NewController(memory.Make(collections.All)) c1 := NewController(store, "pilot-1", time.Duration(math.MaxInt64)) c2 := NewController(store, "pilot-2", time.Duration(math.MaxInt64)) createOrFail(t, store, wgA) createOrFail(t, store, wgAWrongNs) createOrFail(t, store, wgWithoutSA)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller_test.go
netutils "k8s.io/utils/net" "k8s.io/utils/ptr" ) type testController struct { *Controller servicecidrsStore cache.Store ipaddressesStore cache.Store } func newController(ctx context.Context, t *testing.T, cidrs []*networkingapiv1alpha1.ServiceCIDR, ips []*networkingapiv1alpha1.IPAddress) (*fake.Clientset, *testController) { client := fake.NewSimpleClientset()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 22K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller_test.go
DiscoveryController: discovery1, } registry2 := serviceregistry.Simple{ ProviderID: provider.ID("mockAdapter2"), DiscoveryController: discovery2, } ctls := NewController(Options{&mockMeshConfigHolder{}}) ctls.AddRegistry(registry1) ctls.AddRegistry(registry2) return ctls } // return aggregator and cluster1 and cluster2 service discovery
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller_test.go
endpointSliceStore cache.Store serviceStore cache.Store } func newController(ctx context.Context, batchPeriod time.Duration) (*fake.Clientset, *endpointSliceMirroringController) { client := newClientset() informerFactory := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc()) esController := NewController( ctx, informerFactory.Core().V1().Endpoints(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 13.9K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
controllerName = "endpointslice-controller.k8s.io" // topologyQueueItemKey is the key for all items in the topologyQueue. topologyQueueItemKey = "topologyQueueItemKey" ) // NewController creates and initializes a new Controller func NewController(ctx context.Context, podInformer coreinformers.PodInformer, serviceInformer coreinformers.ServiceInformer, nodeInformer coreinformers.NodeInformer,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controlplane/apiserver/server.go
return nil, err } if len(c.SystemNamespaces) > 0 { s.GenericAPIServer.AddPostStartHookOrDie("start-system-namespaces-controller", func(hookContext genericapiserver.PostStartHookContext) error { go systemnamespaces.NewController(c.SystemNamespaces, client, s.VersionedInformers.Core().V1().Namespaces()).Run(hookContext.StopCh) return nil }) } _, publicServicePort, err := c.Generic.SecureServing.HostPort() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 19:24:41 UTC 2024 - 11K bytes - Viewed (0) -
pkg/kubelet/stats/cadvisor_stats_provider_test.go
infos[name] = info } options := cadvisorapiv2.RequestOptions{ IdType: cadvisorapiv2.TypeName, Count: 2, Recursive: true, } mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() mockCadvisor := cadvisortest.NewMockInterface(mockCtrl) mockCadvisor.EXPECT().ContainerInfoV2("/", options).Return(infos, nil) mockCadvisor.EXPECT().RootFsInfo().Return(rootfs, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 30.2K bytes - Viewed (0)