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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
|
package machine
import (
"net"
"net/url"
"os"
"path/filepath"
"github.com/containers/storage/pkg/homedir"
)
type CreateOptions struct {
Name string
CPUS uint64
Memory uint64
IgnitionPath string
ImagePath string
Username string
URI url.URL
IsDefault bool
//KernelPath string
//Devices []VMDevices
}
type RemoteConnectionType string
var (
SSHRemoteConnection RemoteConnectionType = "ssh"
DefaultIgnitionUserName = "core"
)
type Download struct {
Arch string
Artifact string
CompressionType string
Format string
ImageName string `json:"image_name"`
LocalPath string
LocalUncompressedFile string
Sha256sum string
URL *url.URL
VMName string
}
type SSHOptions struct{}
type StartOptions struct{}
type StopOptions struct{}
type DestroyOptions struct {
Force bool
SaveKeys bool
SaveImage bool
SaveIgnition bool
}
type VM interface {
Create(opts CreateOptions) error
Destroy(name string, opts DestroyOptions) (string, func() error, error)
SSH(name string, opts SSHOptions) error
Start(name string, opts StartOptions) error
Stop(name string, opts StopOptions) error
}
type DistributionDownload interface {
DownloadImage() error
Get() *Download
}
// TODO is this even needed?
type TestVM struct{}
func (vm *TestVM) Create(opts CreateOptions) error {
return nil
}
func (vm *TestVM) Start(name string, opts StartOptions) error {
return nil
}
func (vm *TestVM) Stop(name string, opts StopOptions) error {
return nil
}
func (rc RemoteConnectionType) MakeSSHURL(host, path, port, userName string) url.URL {
userInfo := url.User(userName)
uri := url.URL{
Scheme: "ssh",
Opaque: "",
User: userInfo,
Host: host,
Path: path,
RawPath: "",
ForceQuery: false,
RawQuery: "",
Fragment: "",
RawFragment: "",
}
if len(port) > 0 {
uri.Host = net.JoinHostPort(uri.Hostname(), port)
}
return uri
}
// GetDataDir returns the filepath where vm images should
// live for podman-machine
func GetDataDir(vmType string) (string, error) {
data, err := homedir.GetDataHome()
if err != nil {
return "", err
}
dataDir := filepath.Join(data, "containers", "podman", "machine", vmType)
if _, err := os.Stat(dataDir); !os.IsNotExist(err) {
return dataDir, nil
}
mkdirErr := os.MkdirAll(dataDir, 0755)
return dataDir, mkdirErr
}
// GetConfigDir returns the filepath to where configuration
// files for podman-machine should live
func GetConfDir(vmType string) (string, error) {
conf, err := homedir.GetConfigHome()
if err != nil {
return "", err
}
confDir := filepath.Join(conf, "containers", "podman", "machine", vmType)
if _, err := os.Stat(confDir); !os.IsNotExist(err) {
return confDir, nil
}
mkdirErr := os.MkdirAll(confDir, 0755)
return confDir, mkdirErr
}
|
