mirror of
https://github.com/edgelesssys/constellation.git
synced 2024-09-20 16:26:19 +00:00
131 lines
3.4 KiB
Go
131 lines
3.4 KiB
Go
/*
|
|
Copyright (c) Edgeless Systems GmbH
|
|
|
|
SPDX-License-Identifier: AGPL-3.0-only
|
|
*/
|
|
|
|
package k8sapi
|
|
|
|
import (
|
|
"fmt"
|
|
"testing"
|
|
|
|
"github.com/edgelesssys/constellation/v2/internal/versions"
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
"go.uber.org/goleak"
|
|
kubeadmUtil "k8s.io/kubernetes/cmd/kubeadm/app/util"
|
|
)
|
|
|
|
func TestMain(m *testing.M) {
|
|
goleak.VerifyTestMain(m)
|
|
}
|
|
|
|
func TestInitConfiguration(t *testing.T) {
|
|
coreOSConfig := CoreOSConfiguration{}
|
|
|
|
testCases := map[string]struct {
|
|
config KubeadmInitYAML
|
|
}{
|
|
"CoreOS init config can be created": {
|
|
config: coreOSConfig.InitConfiguration(true, versions.Default),
|
|
},
|
|
"CoreOS init config with all fields can be created": {
|
|
config: func() KubeadmInitYAML {
|
|
c := coreOSConfig.InitConfiguration(true, versions.Default)
|
|
c.SetAPIServerAdvertiseAddress("192.0.2.0")
|
|
c.SetNodeIP("192.0.2.0")
|
|
c.SetNodeName("node")
|
|
c.SetPodNetworkCIDR("10.244.0.0/16")
|
|
c.SetServiceCIDR("10.245.0.0/24")
|
|
c.SetProviderID("somecloudprovider://instance-id")
|
|
return c
|
|
}(),
|
|
},
|
|
}
|
|
for name, tc := range testCases {
|
|
t.Run(name, func(t *testing.T) {
|
|
assert := assert.New(t)
|
|
require := require.New(t)
|
|
|
|
config, err := tc.config.Marshal()
|
|
require.NoError(err)
|
|
tmp, err := tc.config.Unmarshal(config)
|
|
require.NoError(err)
|
|
// test on correct mashalling and unmarshalling
|
|
assert.Equal(tc.config.ClusterConfiguration, tmp.ClusterConfiguration)
|
|
assert.Equal(tc.config.InitConfiguration, tmp.InitConfiguration)
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestInitConfigurationKubeadmCompatibility(t *testing.T) {
|
|
coreOSConfig := CoreOSConfiguration{}
|
|
|
|
testCases := map[string]struct {
|
|
config KubeadmInitYAML
|
|
expectedVersion string
|
|
wantErr bool
|
|
}{
|
|
"Kubeadm accepts version 'Latest'": {
|
|
config: coreOSConfig.InitConfiguration(true, versions.Default),
|
|
expectedVersion: fmt.Sprintf("v%s", versions.VersionConfigs[versions.Default].PatchVersion),
|
|
},
|
|
"Kubeadm receives incompatible version": {
|
|
config: coreOSConfig.InitConfiguration(true, "1.19"),
|
|
wantErr: true,
|
|
},
|
|
}
|
|
for name, tc := range testCases {
|
|
t.Run(name, func(t *testing.T) {
|
|
assert := assert.New(t)
|
|
|
|
version, err := kubeadmUtil.KubernetesReleaseVersion(tc.config.ClusterConfiguration.KubernetesVersion)
|
|
if tc.wantErr {
|
|
assert.Error(err)
|
|
return
|
|
}
|
|
assert.Equal(tc.expectedVersion, version)
|
|
assert.NoError(err)
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestJoinConfiguration(t *testing.T) {
|
|
coreOSConfig := CoreOSConfiguration{}
|
|
|
|
testCases := map[string]struct {
|
|
config KubeadmJoinYAML
|
|
}{
|
|
"CoreOS join config can be created": {
|
|
config: coreOSConfig.JoinConfiguration(true),
|
|
},
|
|
"CoreOS join config with all fields can be created": {
|
|
config: func() KubeadmJoinYAML {
|
|
c := coreOSConfig.JoinConfiguration(true)
|
|
c.SetAPIServerEndpoint("192.0.2.0:6443")
|
|
c.SetNodeIP("192.0.2.0")
|
|
c.SetNodeName("node")
|
|
c.SetToken("token")
|
|
c.AppendDiscoveryTokenCaCertHash("discovery-token-ca-cert-hash")
|
|
c.SetProviderID("somecloudprovider://instance-id")
|
|
c.SetControlPlane("192.0.2.0")
|
|
return c
|
|
}(),
|
|
},
|
|
}
|
|
for name, tc := range testCases {
|
|
t.Run(name, func(t *testing.T) {
|
|
assert := assert.New(t)
|
|
require := require.New(t)
|
|
|
|
config, err := tc.config.Marshal()
|
|
require.NoError(err)
|
|
tmp, err := tc.config.Unmarshal(config)
|
|
require.NoError(err)
|
|
// test on correct mashalling and unmarshalling
|
|
assert.Equal(tc.config.JoinConfiguration, tmp.JoinConfiguration)
|
|
})
|
|
}
|
|
}
|