diff --git a/pkg/userdata/amzn2/provider.go b/pkg/userdata/amzn2/provider.go index 05da14cc56..a6ac2cc26f 100644 --- a/pkg/userdata/amzn2/provider.go +++ b/pkg/userdata/amzn2/provider.go @@ -246,7 +246,7 @@ write_files: - path: "/etc/systemd/system/kubelet.service" content: | -{{ kubeletSystemdUnit .ContainerRuntimeName .KubeletVersion .CloudProviderName .MachineSpec.Name .DNSIPs .ExternalCloudProvider .PauseImage .MachineSpec.Taints .ExtraKubeletFlags | indent 4 }} +{{ kubeletSystemdUnit .ContainerRuntimeName .KubeletVersion .KubeletCloudProviderName .MachineSpec.Name .DNSIPs .ExternalCloudProvider .PauseImage .MachineSpec.Taints .ExtraKubeletFlags | indent 4 }} - path: "/etc/kubernetes/cloud-config" permissions: "0600" diff --git a/pkg/userdata/amzn2/provider_test.go b/pkg/userdata/amzn2/provider_test.go index 6d77d9149c..027442cf32 100644 --- a/pkg/userdata/amzn2/provider_test.go +++ b/pkg/userdata/amzn2/provider_test.go @@ -241,16 +241,17 @@ func TestUserDataGeneration(t *testing.T) { } req := plugin.UserDataRequest{ - MachineSpec: test.spec, - Kubeconfig: kubeconfig, - CloudConfig: cloudConfig, - CloudProviderName: cloudProviderName, - DNSIPs: test.clusterDNSIPs, - ExternalCloudProvider: test.externalCloudProvider, - HTTPProxy: test.httpProxy, - NoProxy: test.noProxy, - PauseImage: test.pauseImage, - KubeletFeatureGates: kubeletFeatureGates, + MachineSpec: test.spec, + Kubeconfig: kubeconfig, + CloudConfig: cloudConfig, + CloudProviderName: cloudProvider.name, + KubeletCloudProviderName: cloudProviderName, + DNSIPs: test.clusterDNSIPs, + ExternalCloudProvider: test.externalCloudProvider, + HTTPProxy: test.httpProxy, + NoProxy: test.noProxy, + PauseImage: test.pauseImage, + KubeletFeatureGates: kubeletFeatureGates, ContainerRuntime: containerruntime.Get( test.containerruntime, containerruntime.WithInsecureRegistries(test.insecureRegistries), diff --git a/pkg/userdata/centos/provider.go b/pkg/userdata/centos/provider.go index 9bfeea6431..69673693d2 100644 --- a/pkg/userdata/centos/provider.go +++ b/pkg/userdata/centos/provider.go @@ -246,7 +246,7 @@ write_files: - path: "/etc/systemd/system/kubelet.service" content: | -{{ kubeletSystemdUnit .ContainerRuntimeName .KubeletVersion .CloudProviderName .MachineSpec.Name .DNSIPs .ExternalCloudProvider .PauseImage .MachineSpec.Taints .ExtraKubeletFlags | indent 4 }} +{{ kubeletSystemdUnit .ContainerRuntimeName .KubeletVersion .KubeletCloudProviderName .MachineSpec.Name .DNSIPs .ExternalCloudProvider .PauseImage .MachineSpec.Taints .ExtraKubeletFlags | indent 4 }} - path: "/etc/kubernetes/cloud-config" permissions: "0600" diff --git a/pkg/userdata/centos/provider_test.go b/pkg/userdata/centos/provider_test.go index 55660717b9..08444ae065 100644 --- a/pkg/userdata/centos/provider_test.go +++ b/pkg/userdata/centos/provider_test.go @@ -241,16 +241,17 @@ func TestUserDataGeneration(t *testing.T) { } req := plugin.UserDataRequest{ - MachineSpec: test.spec, - Kubeconfig: kubeconfig, - CloudConfig: cloudConfig, - CloudProviderName: cloudProviderName, - DNSIPs: test.clusterDNSIPs, - ExternalCloudProvider: test.externalCloudProvider, - HTTPProxy: test.httpProxy, - NoProxy: test.noProxy, - PauseImage: test.pauseImage, - KubeletFeatureGates: kubeletFeatureGates, + MachineSpec: test.spec, + Kubeconfig: kubeconfig, + CloudConfig: cloudConfig, + CloudProviderName: cloudProvider.name, + KubeletCloudProviderName: cloudProviderName, + DNSIPs: test.clusterDNSIPs, + ExternalCloudProvider: test.externalCloudProvider, + HTTPProxy: test.httpProxy, + NoProxy: test.noProxy, + PauseImage: test.pauseImage, + KubeletFeatureGates: kubeletFeatureGates, ContainerRuntime: containerruntime.Get( test.containerruntime, containerruntime.WithInsecureRegistries(test.insecureRegistries), diff --git a/pkg/userdata/flatcar/provider.go b/pkg/userdata/flatcar/provider.go index f54814a29e..3bc8ca7b35 100644 --- a/pkg/userdata/flatcar/provider.go +++ b/pkg/userdata/flatcar/provider.go @@ -252,7 +252,7 @@ systemd: Requires=download-script.service After=download-script.service contents: | -{{ kubeletSystemdUnit .ContainerRuntimeName .KubeletVersion .CloudProviderName .MachineSpec.Name .DNSIPs .ExternalCloudProvider .PauseImage .MachineSpec.Taints .ExtraKubeletFlags | indent 8 }} +{{ kubeletSystemdUnit .ContainerRuntimeName .KubeletVersion .KubeletCloudProviderName .MachineSpec.Name .DNSIPs .ExternalCloudProvider .PauseImage .MachineSpec.Taints .ExtraKubeletFlags | indent 8 }} storage: files: @@ -520,7 +520,7 @@ coreos: Requires=download-script.service After=download-script.service content: | -{{ kubeletSystemdUnit .ContainerRuntimeName .KubeletVersion .CloudProviderName .MachineSpec.Name .DNSIPs .ExternalCloudProvider .PauseImage .MachineSpec.Taints .ExtraKubeletFlags | indent 6 }} +{{ kubeletSystemdUnit .ContainerRuntimeName .KubeletVersion .KubeletCloudProviderName .MachineSpec.Name .DNSIPs .ExternalCloudProvider .PauseImage .MachineSpec.Taints .ExtraKubeletFlags | indent 6 }} - name: apply-sysctl-settings.service enable: true diff --git a/pkg/userdata/flatcar/provider_test.go b/pkg/userdata/flatcar/provider_test.go index 9c9509c69c..d9806d26ba 100644 --- a/pkg/userdata/flatcar/provider_test.go +++ b/pkg/userdata/flatcar/provider_test.go @@ -31,7 +31,6 @@ import ( "github.com/kubermatic/machine-controller/pkg/containerruntime" providerconfigtypes "github.com/kubermatic/machine-controller/pkg/providerconfig/types" testhelper "github.com/kubermatic/machine-controller/pkg/test" - "github.com/kubermatic/machine-controller/pkg/userdata/cloud" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" @@ -102,7 +101,7 @@ func (p *fakeCloudConfigProvider) GetCloudConfig(spec clusterv1alpha1.MachineSpe type userDataTestCase struct { name string spec clusterv1alpha1.MachineSpec - ccProvider cloud.ConfigProvider + ccProvider *fakeCloudConfigProvider osConfig *Config providerSpec *providerconfigtypes.Config DNSIPs []net.IP @@ -421,16 +420,17 @@ func TestUserDataGeneration(t *testing.T) { } req := plugin.UserDataRequest{ - MachineSpec: test.spec, - Kubeconfig: kubeconfig, - CloudConfig: cloudConfig, - CloudProviderName: cloudProviderName, - DNSIPs: test.DNSIPs, - ExternalCloudProvider: test.externalCloudProvider, - HTTPProxy: test.httpProxy, - NoProxy: test.noProxy, - PauseImage: test.pauseImage, - KubeletFeatureGates: kubeletFeatureGates, + MachineSpec: test.spec, + Kubeconfig: kubeconfig, + CloudConfig: cloudConfig, + CloudProviderName: test.ccProvider.name, + KubeletCloudProviderName: cloudProviderName, + DNSIPs: test.DNSIPs, + ExternalCloudProvider: test.externalCloudProvider, + HTTPProxy: test.httpProxy, + NoProxy: test.noProxy, + PauseImage: test.pauseImage, + KubeletFeatureGates: kubeletFeatureGates, ContainerRuntime: containerruntime.Get( test.containerruntime, containerruntime.WithInsecureRegistries(test.insecureRegistries), diff --git a/pkg/userdata/rhel/provider.go b/pkg/userdata/rhel/provider.go index 29fa0a5407..4f53467a58 100644 --- a/pkg/userdata/rhel/provider.go +++ b/pkg/userdata/rhel/provider.go @@ -258,7 +258,7 @@ write_files: - path: "/etc/systemd/system/kubelet.service" content: | -{{ kubeletSystemdUnit .ContainerRuntimeName .KubeletVersion .CloudProviderName .MachineSpec.Name .DNSIPs .ExternalCloudProvider .PauseImage .MachineSpec.Taints .ExtraKubeletFlags | indent 4 }} +{{ kubeletSystemdUnit .ContainerRuntimeName .KubeletVersion .KubeletCloudProviderName .MachineSpec.Name .DNSIPs .ExternalCloudProvider .PauseImage .MachineSpec.Taints .ExtraKubeletFlags | indent 4 }} - path: "/etc/kubernetes/cloud-config" permissions: "0600" diff --git a/pkg/userdata/rhel/provider_test.go b/pkg/userdata/rhel/provider_test.go index e1170990dc..be45535827 100644 --- a/pkg/userdata/rhel/provider_test.go +++ b/pkg/userdata/rhel/provider_test.go @@ -241,16 +241,17 @@ func TestUserDataGeneration(t *testing.T) { } req := plugin.UserDataRequest{ - MachineSpec: test.spec, - Kubeconfig: kubeconfig, - CloudConfig: cloudConfig, - CloudProviderName: cloudProviderName, - DNSIPs: test.clusterDNSIPs, - ExternalCloudProvider: test.externalCloudProvider, - HTTPProxy: test.httpProxy, - NoProxy: test.noProxy, - PauseImage: test.pauseImage, - KubeletFeatureGates: kubeletFeatureGates, + MachineSpec: test.spec, + Kubeconfig: kubeconfig, + CloudConfig: cloudConfig, + CloudProviderName: cloudProvider.name, + KubeletCloudProviderName: cloudProviderName, + DNSIPs: test.clusterDNSIPs, + ExternalCloudProvider: test.externalCloudProvider, + HTTPProxy: test.httpProxy, + NoProxy: test.noProxy, + PauseImage: test.pauseImage, + KubeletFeatureGates: kubeletFeatureGates, ContainerRuntime: containerruntime.Get( test.containerruntime, containerruntime.WithInsecureRegistries(test.insecureRegistries), diff --git a/pkg/userdata/sles/provider.go b/pkg/userdata/sles/provider.go index a3a5583e75..4ccdb75b6a 100644 --- a/pkg/userdata/sles/provider.go +++ b/pkg/userdata/sles/provider.go @@ -202,7 +202,7 @@ write_files: - path: "/etc/systemd/system/kubelet.service" content: | -{{ kubeletSystemdUnit .ContainerRuntime.String .KubeletVersion .CloudProviderName .MachineSpec.Name .DNSIPs .ExternalCloudProvider .PauseImage .MachineSpec.Taints .ExtraKubeletFlags | indent 4 }} +{{ kubeletSystemdUnit .ContainerRuntime.String .KubeletVersion .KubeletCloudProviderName .MachineSpec.Name .DNSIPs .ExternalCloudProvider .PauseImage .MachineSpec.Taints .ExtraKubeletFlags | indent 4 }} - path: "/etc/systemd/system/kubelet.service.d/extras.conf" content: | diff --git a/pkg/userdata/sles/provider_test.go b/pkg/userdata/sles/provider_test.go index f4d64cfea9..452768b1b2 100644 --- a/pkg/userdata/sles/provider_test.go +++ b/pkg/userdata/sles/provider_test.go @@ -34,7 +34,6 @@ import ( "github.com/kubermatic/machine-controller/pkg/containerruntime" providerconfigtypes "github.com/kubermatic/machine-controller/pkg/providerconfig/types" testhelper "github.com/kubermatic/machine-controller/pkg/test" - "github.com/kubermatic/machine-controller/pkg/userdata/cloud" "github.com/kubermatic/machine-controller/pkg/userdata/convert" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" @@ -110,7 +109,7 @@ func (p *fakeCloudConfigProvider) GetCloudConfig(spec clusterv1alpha1.MachineSpe type userDataTestCase struct { name string spec clusterv1alpha1.MachineSpec - ccProvider cloud.ConfigProvider + ccProvider *fakeCloudConfigProvider osConfig *Config providerSpec *providerconfigtypes.Config DNSIPs []net.IP @@ -438,16 +437,17 @@ func TestUserDataGeneration(t *testing.T) { } req := plugin.UserDataRequest{ - MachineSpec: test.spec, - Kubeconfig: kubeconfig, - CloudConfig: cloudConfig, - CloudProviderName: cloudProviderName, - DNSIPs: test.DNSIPs, - ExternalCloudProvider: test.externalCloudProvider, - HTTPProxy: test.httpProxy, - NoProxy: test.noProxy, - PauseImage: test.pauseImage, - KubeletFeatureGates: kubeletFeatureGates, + MachineSpec: test.spec, + Kubeconfig: kubeconfig, + CloudConfig: cloudConfig, + CloudProviderName: test.ccProvider.name, + KubeletCloudProviderName: cloudProviderName, + DNSIPs: test.DNSIPs, + ExternalCloudProvider: test.externalCloudProvider, + HTTPProxy: test.httpProxy, + NoProxy: test.noProxy, + PauseImage: test.pauseImage, + KubeletFeatureGates: kubeletFeatureGates, ContainerRuntime: containerruntime.Get( test.containerruntime, containerruntime.WithInsecureRegistries(test.insecureRegistries), diff --git a/pkg/userdata/ubuntu/provider.go b/pkg/userdata/ubuntu/provider.go index 803275db83..5d26595a19 100644 --- a/pkg/userdata/ubuntu/provider.go +++ b/pkg/userdata/ubuntu/provider.go @@ -247,7 +247,7 @@ write_files: - path: "/etc/systemd/system/kubelet.service" content: | -{{ kubeletSystemdUnit .ContainerRuntimeName .KubeletVersion .CloudProviderName .MachineSpec.Name .DNSIPs .ExternalCloudProvider .PauseImage .MachineSpec.Taints .ExtraKubeletFlags | indent 4 }} +{{ kubeletSystemdUnit .ContainerRuntimeName .KubeletVersion .KubeletCloudProviderName .MachineSpec.Name .DNSIPs .ExternalCloudProvider .PauseImage .MachineSpec.Taints .ExtraKubeletFlags | indent 4 }} - path: "/etc/systemd/system/kubelet.service.d/extras.conf" content: | diff --git a/pkg/userdata/ubuntu/provider_test.go b/pkg/userdata/ubuntu/provider_test.go index 6bc781b428..310deace9b 100644 --- a/pkg/userdata/ubuntu/provider_test.go +++ b/pkg/userdata/ubuntu/provider_test.go @@ -34,7 +34,6 @@ import ( "github.com/kubermatic/machine-controller/pkg/containerruntime" providerconfigtypes "github.com/kubermatic/machine-controller/pkg/providerconfig/types" testhelper "github.com/kubermatic/machine-controller/pkg/test" - "github.com/kubermatic/machine-controller/pkg/userdata/cloud" "github.com/kubermatic/machine-controller/pkg/userdata/convert" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" @@ -109,7 +108,7 @@ func (p *fakeCloudConfigProvider) GetCloudConfig(spec clusterv1alpha1.MachineSpe type userDataTestCase struct { name string spec clusterv1alpha1.MachineSpec - ccProvider cloud.ConfigProvider + ccProvider *fakeCloudConfigProvider osConfig *Config providerSpec *providerconfigtypes.Config DNSIPs []net.IP @@ -474,16 +473,17 @@ func TestUserDataGeneration(t *testing.T) { } req := plugin.UserDataRequest{ - MachineSpec: test.spec, - Kubeconfig: kubeconfig, - CloudConfig: cloudConfig, - CloudProviderName: cloudProviderName, - DNSIPs: test.DNSIPs, - ExternalCloudProvider: test.externalCloudProvider, - HTTPProxy: test.httpProxy, - NoProxy: test.noProxy, - PauseImage: test.pauseImage, - KubeletFeatureGates: kubeletFeatureGates, + MachineSpec: test.spec, + Kubeconfig: kubeconfig, + CloudConfig: cloudConfig, + CloudProviderName: test.ccProvider.name, + KubeletCloudProviderName: cloudProviderName, + DNSIPs: test.DNSIPs, + ExternalCloudProvider: test.externalCloudProvider, + HTTPProxy: test.httpProxy, + NoProxy: test.noProxy, + PauseImage: test.pauseImage, + KubeletFeatureGates: kubeletFeatureGates, ContainerRuntime: containerruntime.Get( test.containerruntime, containerruntime.WithInsecureRegistries(test.insecureRegistries),