- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 80 for newController (0.58 sec)
-
pilot/pkg/config/kube/gateway/controller_test.go
return true } func TestListInvalidGroupVersionKind(t *testing.T) { g := NewWithT(t) clientSet := kube.NewFakeClient() clientSet.RunAndWait(test.NewStop(t)) store := memory.NewController(memory.Make(collections.All)) controller := NewController(clientSet, store, AlwaysReady, nil, controller.Options{}) typ := config.GroupVersionKind{Kind: "wrong-kind"} c := controller.List(typ, "ns1") g.Expect(c).To(HaveLen(0)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 16:47:06 UTC 2024 - 5.6K bytes - Viewed (0) -
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) -
pkg/controlplane/controller/systemnamespaces/system_namespaces_controller.go
namespaceLister listers.NamespaceLister namespaceSynced cache.InformerSynced systemNamespaces []string interval time.Duration } // NewController creates a new Controller to ensure system namespaces exist. func NewController(systemNamespaces []string, clientset kubernetes.Interface, namespaceInformer coreinformers.NamespaceInformer) *Controller { interval := 1 * time.Minute return &Controller{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 2.9K 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) -
pkg/controlplane/controller/legacytokentracking/controller.go
// or disabled. creationRatelimiter *rate.Limiter clock clock.Clock } // NewController returns a Controller struct. func NewController(cs kubernetes.Interface) *Controller { return newController(cs, clock.RealClock{}, rate.NewLimiter(rate.Every(30*time.Minute), 1)) } func newController(cs kubernetes.Interface, cl clock.Clock, limiter *rate.Limiter) *Controller {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
}) return httptest.NewServer(mux) } type endpointController struct { *Controller podStore cache.Store serviceStore cache.Store endpointsStore cache.Store } func newController(ctx context.Context, url string, batchPeriod time.Duration) *endpointController {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K 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) -
pilot/pkg/serviceregistry/kube/controller/fake.go
} f := namespace.NewDiscoveryNamespacesFilter( kclient.New[*corev1.Namespace](opts.Client), opts.MeshWatcher, stop, ) kubelib.SetObjectFilter(opts.Client, f) meshServiceController := aggregate.NewController(aggregate.Options{MeshHolder: opts.MeshWatcher}) options := Options{ DomainSuffix: domainSuffix, XDSUpdater: xdsUpdater, Metrics: &model.Environment{},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 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)