Make GlobalArgs vs StartArgs more explicit

pull/4744/head
tstromberg 2019-07-12 16:57:23 -07:00
parent 69b90f0d6e
commit 21ab32eaf8
6 changed files with 12 additions and 13 deletions

View File

@ -28,7 +28,7 @@ import (
func TestDocker(t *testing.T) { func TestDocker(t *testing.T) {
mk := NewMinikubeRunner(t, "--wait=false") mk := NewMinikubeRunner(t, "--wait=false")
if strings.Contains(mk.StartArgs, "--vm-driver=none") { if usingNoneDriver(mk) {
t.Skip("skipping test as none driver does not bundle docker") t.Skip("skipping test as none driver does not bundle docker")
} }
@ -40,7 +40,7 @@ func TestDocker(t *testing.T) {
t.Logf("pre-delete failed (probably ok): %v", err) t.Logf("pre-delete failed (probably ok): %v", err)
} }
startCmd := fmt.Sprintf("start %s %s %s", mk.StartArgs, mk.Args, startCmd := fmt.Sprintf("start %s %s %s", mk.StartArgs, mk.GlobalArgs,
"--docker-env=FOO=BAR --docker-env=BAZ=BAT --docker-opt=debug --docker-opt=icc=true") "--docker-env=FOO=BAR --docker-env=BAZ=BAT --docker-opt=debug --docker-opt=icc=true")
stdout, stderr, err := mk.RunWithContext(ctx, startCmd) stdout, stderr, err := mk.RunWithContext(ctx, startCmd)
if err != nil { if err != nil {

View File

@ -32,7 +32,7 @@ func TestMain(m *testing.M) {
} }
var binaryPath = flag.String("binary", "../../out/minikube", "path to minikube binary") var binaryPath = flag.String("binary", "../../out/minikube", "path to minikube binary")
var args = flag.String("minikube-args", "", "Arguments to pass to minikube") var globalArgs = flag.String("minikube-args", "", "Arguments to pass to minikube")
var startArgs = flag.String("minikube-start-args", "", "Arguments to pass to minikube start") var startArgs = flag.String("minikube-start-args", "", "Arguments to pass to minikube start")
var mountArgs = flag.String("minikube-mount-args", "", "Arguments to pass to minikube mount") var mountArgs = flag.String("minikube-mount-args", "", "Arguments to pass to minikube mount")
var testdataDir = flag.String("testdata-dir", "testdata", "the directory relative to test/integration where the testdata lives") var testdataDir = flag.String("testdata-dir", "testdata", "the directory relative to test/integration where the testdata lives")
@ -40,9 +40,9 @@ var testdataDir = flag.String("testdata-dir", "testdata", "the directory relativ
// NewMinikubeRunner creates a new MinikubeRunner // NewMinikubeRunner creates a new MinikubeRunner
func NewMinikubeRunner(t *testing.T, extraArgs ...string) util.MinikubeRunner { func NewMinikubeRunner(t *testing.T, extraArgs ...string) util.MinikubeRunner {
return util.MinikubeRunner{ return util.MinikubeRunner{
Args: *args + strings.Join(extraArgs, " "),
BinaryPath: *binaryPath, BinaryPath: *binaryPath,
StartArgs: *startArgs, StartArgs: *startArgs + strings.Join(extraArgs, " "),
GlobalArgs: *globalArgs,
MountArgs: *mountArgs, MountArgs: *mountArgs,
T: t, T: t,
} }

View File

@ -38,7 +38,7 @@ func testMounting(t *testing.T) {
if runtime.GOOS == "darwin" { if runtime.GOOS == "darwin" {
t.Skip("mount tests disabled in darwin due to timeout (issue#3200)") t.Skip("mount tests disabled in darwin due to timeout (issue#3200)")
} }
if strings.Contains(*args, "--vm-driver=none") { if strings.Contains(*globalArgs, "--vm-driver=none") {
t.Skip("skipping test for none driver as it does not need mount") t.Skip("skipping test for none driver as it does not need mount")
} }

View File

@ -21,7 +21,6 @@ package integration
import ( import (
"path" "path"
"path/filepath" "path/filepath"
"strings"
"testing" "testing"
"time" "time"
@ -31,7 +30,7 @@ import (
func TestPersistence(t *testing.T) { func TestPersistence(t *testing.T) {
mk := NewMinikubeRunner(t, "--wait=false") mk := NewMinikubeRunner(t, "--wait=false")
if strings.Contains(mk.StartArgs, "--vm-driver=none") { if usingNoneDriver(mk) {
t.Skip("skipping test as none driver does not support persistence") t.Skip("skipping test as none driver does not support persistence")
} }
mk.EnsureRunning() mk.EnsureRunning()

View File

@ -112,7 +112,7 @@ func testProxyWarning(t *testing.T) {
r := NewMinikubeRunner(t, "--wait=false") r := NewMinikubeRunner(t, "--wait=false")
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Minute) ctx, cancel := context.WithTimeout(context.Background(), 10*time.Minute)
defer cancel() defer cancel()
startCmd := fmt.Sprintf("start %s %s %s", r.StartArgs, r.Args, "--alsologtostderr --v=5") startCmd := fmt.Sprintf("start %s %s", r.StartArgs, r.GlobalArgs)
stdout, stderr, err := r.RunWithContext(ctx, startCmd) stdout, stderr, err := r.RunWithContext(ctx, startCmd)
if err != nil { if err != nil {
t.Fatalf("start: %v\nstdout: %s\nstderr: %s", err, stdout, stderr) t.Fatalf("start: %v\nstdout: %s\nstderr: %s", err, stdout, stderr)

View File

@ -43,7 +43,7 @@ const kubectlBinary = "kubectl"
type MinikubeRunner struct { type MinikubeRunner struct {
T *testing.T T *testing.T
BinaryPath string BinaryPath string
Args string GlobalArgs string
StartArgs string StartArgs string
MountArgs string MountArgs string
Runtime string Runtime string
@ -210,7 +210,7 @@ func (m *MinikubeRunner) SSH(command string) (string, error) {
// Start starts the cluster // Start starts the cluster
func (m *MinikubeRunner) Start(opts ...string) { func (m *MinikubeRunner) Start(opts ...string) {
cmd := fmt.Sprintf("start %s %s %s --alsologtostderr --v=2", m.StartArgs, m.Args, strings.Join(opts, " ")) cmd := fmt.Sprintf("start %s %s %s --alsologtostderr --v=2", m.StartArgs, m.GlobalArgs, strings.Join(opts, " "))
m.RunCommand(cmd, true) m.RunCommand(cmd, true)
} }
@ -234,12 +234,12 @@ func (m *MinikubeRunner) ParseEnvCmdOutput(out string) map[string]string {
// GetStatus returns the status of a service // GetStatus returns the status of a service
func (m *MinikubeRunner) GetStatus() string { func (m *MinikubeRunner) GetStatus() string {
return m.RunCommand(fmt.Sprintf("status --format={{.Host}} %s", m.Args), false) return m.RunCommand(fmt.Sprintf("status --format={{.Host}} %s", m.GlobalArgs), false)
} }
// GetLogs returns the logs of a service // GetLogs returns the logs of a service
func (m *MinikubeRunner) GetLogs() string { func (m *MinikubeRunner) GetLogs() string {
return m.RunCommand(fmt.Sprintf("logs %s", m.Args), true) return m.RunCommand(fmt.Sprintf("logs %s", m.GlobalArgs), true)
} }
// CheckStatus makes sure the service has the desired status, or cause fatal error // CheckStatus makes sure the service has the desired status, or cause fatal error