1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
package oc
import (
"path/filepath"
"github.com/crc-org/crc/v2/pkg/crc/constants"
"github.com/crc-org/crc/v2/pkg/crc/ssh"
crcos "github.com/crc-org/crc/v2/pkg/os"
)
const (
defaultTimeout = "30s"
fastTimeout = "5s"
)
type Config struct {
Runner crcos.CommandRunner
OcExecutablePath string
KubeconfigPath string
Context string
Cluster string
Timeout string
}
// UseOcWithConfig return the oc executable along with valid kubeconfig
func UseOCWithConfig(machineName string) Config {
return Config{
Runner: crcos.NewLocalCommandRunner(),
OcExecutablePath: filepath.Join(constants.CrcOcBinDir, constants.OcExecutableName),
KubeconfigPath: filepath.Join(constants.MachineInstanceDir, machineName, "kubeconfig"),
Context: constants.DefaultContext,
Cluster: constants.DefaultName,
Timeout: defaultTimeout,
}
}
func (oc Config) WithFailFast() Config {
return Config{
Runner: oc.Runner,
OcExecutablePath: oc.OcExecutablePath,
KubeconfigPath: oc.KubeconfigPath,
Context: oc.Context,
Cluster: oc.Cluster,
Timeout: fastTimeout,
}
}
func (oc Config) runCommand(isPrivate bool, args ...string) (string, string, error) {
if oc.Context != "" {
args = append(args, "--context", oc.Context)
}
if oc.Cluster != "" {
args = append(args, "--cluster", oc.Cluster)
}
if oc.KubeconfigPath != "" {
args = append(args, "--kubeconfig", oc.KubeconfigPath)
}
if isPrivate {
return oc.Runner.RunPrivate("timeout", append([]string{oc.Timeout, oc.OcExecutablePath}, args...)...)
}
return oc.Runner.Run("timeout", append([]string{oc.Timeout, oc.OcExecutablePath}, args...)...)
}
func (oc Config) RunOcCommand(args ...string) (string, string, error) {
return oc.runCommand(false, args...)
}
func (oc Config) RunOcCommandPrivate(args ...string) (string, string, error) {
return oc.runCommand(true, args...)
}
type SSHRunner struct {
Runner *ssh.Runner
}
func UseOCWithSSH(sshRunner *ssh.Runner) Config {
return Config{
Runner: sshRunner,
OcExecutablePath: "oc",
KubeconfigPath: "/opt/kubeconfig",
Context: constants.DefaultContext,
Cluster: constants.DefaultName,
Timeout: defaultTimeout,
}
}
|
