start_stop_delete_test.go 2.1 KB
Newer Older
D
dlorenc 已提交
1 2 3
// +build integration

/*
4
Copyright 2016 The Kubernetes Authors All rights reserved.
5

D
dlorenc 已提交
6 7 8
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
9

D
dlorenc 已提交
10
    http://www.apache.org/licenses/LICENSE-2.0
11

D
dlorenc 已提交
12 13 14 15 16 17 18 19 20 21
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

package integration

import (
D
Dan Lorenc 已提交
22 23
	"net"
	"strings"
D
dlorenc 已提交
24
	"testing"
25
	"time"
26

A
Aaron Prindle 已提交
27
	"github.com/docker/machine/libmachine/state"
28
	"k8s.io/minikube/test/integration/util"
D
dlorenc 已提交
29 30 31
)

func TestStartStop(t *testing.T) {
32
	tests := []struct {
33 34
		name string
		args []string
35
	}{
36 37 38
		{"docker+cache", []string{"--container-runtime=docker", "--cache-images"}},
		{"containerd+cache", []string{"--container-runtime=containerd", "--docker-opt containerd=/var/run/containerd/containerd.sock", "--cache-images"}},
		{"crio+cache", []string{"--container-runtime=crio", "--cache-images"}},
39
	}
D
dlorenc 已提交
40

41
	for _, test := range tests {
42 43 44 45
		t.Run(test.name, func(t *testing.T) {
			r := NewMinikubeRunner(t)
			if !strings.Contains(test.name, "docker") && usingNoneDriver(r) {
				t.Skipf("skipping %s - incompatible with none driver", test.name)
46
			}
D
dlorenc 已提交
47

48 49 50 51 52
			r.RunCommand("config set WantReportErrorPrompt false", true)
			r.RunCommand("delete", false)
			r.CheckStatus(state.None.String())
			r.Start(test.args...)
			r.CheckStatus(state.Running.String())
D
dlorenc 已提交
53

54
			ip := r.RunCommand("ip", true)
55 56 57 58
			ip = strings.TrimRight(ip, "\n")
			if net.ParseIP(ip) == nil {
				t.Fatalf("IP command returned an invalid address: %s", ip)
			}
59

60
			checkStop := func() error {
61 62
				r.RunCommand("stop", true)
				return r.CheckStatusNoFail(state.Stopped.String())
63 64 65 66 67
			}

			if err := util.Retry(t, checkStop, 5*time.Second, 6); err != nil {
				t.Fatalf("timed out while checking stopped status: %v", err)
			}
D
dlorenc 已提交
68

69 70
			r.Start()
			r.CheckStatus(state.Running.String())
D
dlorenc 已提交
71

72 73
			r.RunCommand("delete", true)
			r.CheckStatus(state.None.String())
74 75
		})
	}
D
dlorenc 已提交
76
}