mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-10 04:27:54 +00:00
kubeadm: increase ut coverage of util/config
Signed-off-by: xin.li <xin.li@daocloud.io>
This commit is contained in:
parent
22cb31467d
commit
20b67a4d1a
@ -22,6 +22,9 @@ import (
|
|||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/lithammer/dedent"
|
"github.com/lithammer/dedent"
|
||||||
|
"github.com/stretchr/testify/assert"
|
||||||
|
|
||||||
|
kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestLoadResetConfigurationFromFile(t *testing.T) {
|
func TestLoadResetConfigurationFromFile(t *testing.T) {
|
||||||
@ -98,3 +101,53 @@ func TestLoadResetConfigurationFromFile(t *testing.T) {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestSetResetDynamicDefaults(t *testing.T) {
|
||||||
|
type args struct {
|
||||||
|
cfg *kubeadmapi.ResetConfiguration
|
||||||
|
skipCRIDetect bool
|
||||||
|
}
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
args args
|
||||||
|
}{
|
||||||
|
{
|
||||||
|
name: "CRISocket is empty and skipCRIDetect is true",
|
||||||
|
args: args{
|
||||||
|
cfg: &kubeadmapi.ResetConfiguration{},
|
||||||
|
skipCRIDetect: true,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "CRISocket is empty and skipCRIDetect is false",
|
||||||
|
args: args{
|
||||||
|
cfg: &kubeadmapi.ResetConfiguration{},
|
||||||
|
skipCRIDetect: false,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "CRISocket is valid",
|
||||||
|
args: args{
|
||||||
|
cfg: &kubeadmapi.ResetConfiguration{
|
||||||
|
CRISocket: "unix:///var/run/containerd/containerd.sock",
|
||||||
|
},
|
||||||
|
skipCRIDetect: false,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "CRISocket is invalid",
|
||||||
|
args: args{
|
||||||
|
cfg: &kubeadmapi.ResetConfiguration{
|
||||||
|
CRISocket: "var/run/containerd/containerd.sock",
|
||||||
|
},
|
||||||
|
skipCRIDetect: false,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
for _, rt := range tests {
|
||||||
|
t.Run(rt.name, func(t *testing.T) {
|
||||||
|
err := SetResetDynamicDefaults(rt.args.cfg, rt.args.skipCRIDetect)
|
||||||
|
assert.NoError(t, err)
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user