- Sort Score
- Result 10 results
- Languages All
Results 41 - 45 of 45 for newController (0.13 sec)
-
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) -
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) -
pkg/controller/volume/persistentvolume/framework_test.go
PodInformer: informerFactory.Core().V1().Pods(), NodeInformer: informerFactory.Core().V1().Nodes(), EnableDynamicProvisioning: enableDynamicProvisioning, } ctrl, err := NewController(ctx, params) if err != nil { return nil, fmt.Errorf("failed to construct persistentvolume controller: %v", err) } ctrl.eventRecorder = record.NewFakeRecorder(1000) ctrl.volumeListerSynced = alwaysReady
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 09:54:00 UTC 2023 - 38.3K bytes - Viewed (0)