- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 103 for newController (0.76 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/registry/core/replicationcontroller/strategy.go
func (rcStrategy) PrepareForUpdate(ctx context.Context, obj, old runtime.Object) { newController := obj.(*api.ReplicationController) oldController := old.(*api.ReplicationController) // update is not allowed to set status newController.Status = oldController.Status pod.DropDisabledTemplateFields(newController.Spec.Template, oldController.Spec.Template)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 16 21:06:10 UTC 2022 - 9.7K 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) -
cmd/kube-controller-manager/app/discovery.go
} } func startEndpointSliceController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { go endpointslicecontroller.NewController( ctx, controllerContext.InformerFactory.Core().V1().Pods(), controllerContext.InformerFactory.Core().V1().Services(), controllerContext.InformerFactory.Core().V1().Nodes(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 11:28:02 UTC 2023 - 3.1K bytes - Viewed (0) -
pilot/pkg/autoregistration/internal/health/controller.go
type Controller struct { stateStore *state.Store // healthCondition is a fifo queue used for updating health check status healthCondition controllers.Queue } // NewController returns a new Controller instance. func NewController(stateStore *state.Store, maxRetries int) *Controller { c := &Controller{ stateStore: stateStore, } c.healthCondition = controllers.NewQueue("healthcheck",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Sep 19 20:41:55 UTC 2023 - 3.4K 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)