@@ -38,6 +38,7 @@ import (
3838const (
3939 machineProviderIDIndex = "machineProviderIDIndex"
4040 nodeProviderIDIndex = "nodeProviderIDIndex"
41+ defaultMachineAPI = "v1alpha2.cluster.x-k8s.io"
4142)
4243
4344// machineController watches for Nodes, Machines, MachineSets and
@@ -280,14 +281,15 @@ func newMachineController(
280281 kubeInformerFactory := kubeinformers .NewSharedInformerFactory (kubeclient , 0 )
281282 informerFactory := dynamicinformer .NewFilteredDynamicSharedInformerFactory (dynamicclient , 0 , metav1 .NamespaceAll , nil )
282283
283- machineDeploymentResource , _ := schema .ParseResourceArg ("machinedeployments.v1alpha2.cluster.x-k8s.io" )
284+ // TODO(alberto): let environment variable to override defaultMachineAPI
285+ machineDeploymentResource , _ := schema .ParseResourceArg (fmt .Sprintf ("machinedeployments.%v" , defaultMachineAPI ))
284286
285- machineSetResource , _ := schema .ParseResourceArg ("machinesets.v1alpha2.cluster.x-k8s.io" )
287+ machineSetResource , _ := schema .ParseResourceArg (fmt . Sprintf ( "machinesets.%v" , defaultMachineAPI ) )
286288 if machineSetResource == nil {
287289 panic ("MachineSetResource" )
288290 }
289291
290- machineResource , _ := schema .ParseResourceArg ("machines.v1alpha2.cluster.x-k8s.io" )
292+ machineResource , _ := schema .ParseResourceArg (fmt . Sprintf ( "machines.%v" , defaultMachineAPI ) )
291293 if machineResource == nil {
292294 panic ("machineResource" )
293295 }
0 commit comments