- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 106 for newController (0.23 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
return fmt.Errorf("expected equal objects: %v", cmp.Diff(obj, reconciledObj)) case <-ctx.Done(): return fmt.Errorf("context done before reconcile: %w", ctx.Err()) } } myController := generic.NewController( generic.NewInformer[*unstructured.Unstructured](informer), reconciler, generic.ControllerOptions{}, ) verifyNoMoreEvents = func() bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/controller.go
statusController *atomic.Pointer[status.Controller] waitForCRD func(class schema.GroupVersionResource, stop <-chan struct{}) bool } var _ model.GatewayController = &Controller{} func NewController( kc kube.Client, c model.ConfigStoreController, waitForCRD func(class schema.GroupVersionResource, stop <-chan struct{}) bool, credsController credentials.MulticlusterController, options controller.Options,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_gc_test.go
} podStateProvider.removed["012"] = struct{}{} podStateProvider.removed["789"] = struct{}{} podStateProvider.removed["654"] = struct{}{} ctrl := gomock.NewController(t) defer ctrl.Finish() fakeOS.ReadDirFn = func(string) ([]os.DirEntry, error) { var dirEntries []os.DirEntry for _, file := range files { mockDE := containertest.NewMockDirEntry(ctrl)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 20.6K bytes - Viewed (0) -
pkg/controlplane/instance.go
s.ControlPlane.GenericAPIServer.AddPostStartHookOrDie("start-kubernetes-service-cidr-controller", func(hookContext genericapiserver.PostStartHookContext) error { controller := defaultservicecidr.NewController( c.Extra.ServiceIPRange, c.Extra.SecondaryServiceIPRange, client, ) // The default serviceCIDR must exist before the apiserver is healthy
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.2K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller_test.go
claimInformer := informerFactory.Resource().V1alpha2().ResourceClaims() templateInformer := informerFactory.Resource().V1alpha2().ResourceClaimTemplates() ec, err := NewController(klog.FromContext(ctx), fakeKubeClient, podInformer, podSchedulingInformer, claimInformer, templateInformer) if err != nil { t.Fatalf("error creating ephemeral controller : %v", err) }
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/controller/resourceclaim/controller.go
// that a ReservedFor entry needs to be removed. deletedObjects *uidCache } const ( claimKeyPrefix = "claim:" podKeyPrefix = "pod:" ) // NewController creates a ResourceClaim controller. func NewController( logger klog.Logger, kubeClient clientset.Interface, podInformer v1informers.PodInformer, podSchedulingInformer resourcev1alpha2informers.PodSchedulingContextInformer,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
podsClient kclient.Client[*v1.Pod] configCluster bool networksHandlerRegistration *mesh.WatcherHandlerRegistration } // NewController creates a new Kubernetes controller // Created by bootstrap and multicluster (see multicluster.Controller). func NewController(kubeClient kubelib.Client, options Options) *Controller { c := &Controller{ opts: options, client: kubeClient,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
e := model.NewEnvironment() e.DomainSuffix = args.RegistryOptions.KubeOptions.DomainSuffix e.SetLedger(buildLedger(args.RegistryOptions)) ac := aggregate.NewController(aggregate.Options{ MeshHolder: e, }) e.ServiceDiscovery = ac s := &Server{ clusterID: getClusterID(args), environment: e,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
configController := memory.NewController(store) stop := test.NewStop(t) go configController.Run(stop) fx := xdsfake.NewFakeXDS() go func() { for { select { case <-stop: return case <-fx.Events: // drain } } }() meshcfg := mesh.NewFixedWatcher(mesh.DefaultMeshConfig()) serviceController := NewController(configController, fx, meshcfg)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller_test.go
InformersStarted: alwaysStarted, InformerFactory: informerFactory, } _, ctx := ktesting.NewTestContext(t) qc, err := NewController(ctx, resourceQuotaControllerOptions) if err != nil { t.Fatal(err) } stop := make(chan struct{}) informerFactory.Start(stop) return quotaController{qc, stop} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 16:29:33 UTC 2023 - 42.6K bytes - Viewed (0)