Expose Configurer, add interface checks

Author: kke

configurer/interface.go

@@ -0,0 +1,61 @@
+package configurer
+
+import (
+	"time"
+
+	"github.com/k0sproject/rig/exec"
+	"github.com/k0sproject/rig/os"
+)
+
+// Configurer defines the per-host operations required for managing a host.
+type Configurer interface {
+	Kind() string
+	OSKind() string
+	CheckPrivilege(os.Host) error
+	StartService(os.Host, string) error
+	StopService(os.Host, string) error
+	RestartService(os.Host, string) error
+	ServiceIsRunning(os.Host, string) bool
+	Arch(os.Host) (string, error)
+	K0sCmdf(string, ...interface{}) string
+	K0sBinaryPath() string
+	K0sConfigPath() string
+	DataDirDefaultPath() string
+	K0sJoinTokenPath() string
+	WriteFile(os.Host, string, string, string) error
+	UpdateEnvironment(os.Host, map[string]string) error
+	DaemonReload(os.Host) error
+	ReplaceK0sTokenPath(os.Host, string) error
+	ServiceScriptPath(os.Host, string) (string, error)
+	ReadFile(os.Host, string) (string, error)
+	FileExist(os.Host, string) bool
+	Chmod(os.Host, string, string, ...exec.Option) error
+	Chown(os.Host, string, string, ...exec.Option) error
+	DownloadURL(os.Host, string, string, ...exec.Option) error
+	InstallPackage(os.Host, ...string) error
+	FileContains(os.Host, string, string) bool
+	MoveFile(os.Host, string, string) error
+	MkDir(os.Host, string, ...exec.Option) error
+	DeleteFile(os.Host, string) error
+	CommandExist(os.Host, string) bool
+	Hostname(os.Host) string
+	KubectlCmdf(os.Host, string, string, ...interface{}) string
+	KubeconfigPath(os.Host, string) string
+	IsContainer(os.Host) bool
+	FixContainer(os.Host) error
+	HTTPStatus(os.Host, string) (int, error)
+	PrivateInterface(os.Host) (string, error)
+	PrivateAddress(os.Host, string, string) (string, error)
+	TempDir(os.Host) (string, error)
+	TempFile(os.Host) (string, error)
+	UpdateServiceEnvironment(os.Host, string, map[string]string) error
+	CleanupServiceEnvironment(os.Host, string) error
+	Stat(os.Host, string, ...exec.Option) (*os.FileInfo, error)
+	DeleteDir(os.Host, string, ...exec.Option) error
+	K0sctlLockFilePath(os.Host) string
+	UpsertFile(os.Host, string, string) error
+	MachineID(os.Host) (string, error)
+	SetPath(string, string)
+	SystemTime(os.Host) (time.Time, error)
+	Touch(os.Host, string, time.Time, ...exec.Option) error
+}

configurer/linux/alpine.go

@@ -21,6 +21,8 @@ type Alpine struct {
 	BaseLinux
 }
 
+var _ configurer.Configurer = (*Alpine)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {

configurer/linux/archlinux.go

@@ -13,6 +13,8 @@ type Archlinux struct {
 	configurer.Linux
 }
 
+var _ configurer.Configurer = (*Archlinux)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {

configurer/linux/coreos.go

@@ -4,6 +4,7 @@ import (
 	"errors"
 	"strings"
 
+	"github.com/k0sproject/k0sctl/configurer"
 	"github.com/k0sproject/rig"
 	"github.com/k0sproject/rig/os"
 	"github.com/k0sproject/rig/os/registry"
@@ -15,6 +16,8 @@ type CoreOS struct {
 	BaseLinux
 }
 
+var _ configurer.Configurer = (*CoreOS)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {

configurer/linux/debian.go

@@ -13,6 +13,8 @@ type Debian struct {
 	configurer.Linux
 }
 
+var _ configurer.Configurer = (*Debian)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {

configurer/linux/enterpriselinux/almalinux.go

@@ -13,6 +13,8 @@ type AlmaLinux struct {
 	configurer.Linux
 }
 
+var _ configurer.Configurer = (*AlmaLinux)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {

configurer/linux/enterpriselinux/amazon.go

@@ -14,6 +14,8 @@ type AmazonLinux struct {
 	configurer.Linux
 }
 
+var _ configurer.Configurer = (*AmazonLinux)(nil)
+
 // Hostname on amazon linux will return the full hostname
 func (l *AmazonLinux) Hostname(h os.Host) string {
 	hostname, _ := h.ExecOutput("hostname")

configurer/linux/enterpriselinux/centos.go

@@ -13,6 +13,8 @@ type CentOS struct {
 	configurer.Linux
 }
 
+var _ configurer.Configurer = (*CentOS)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {

configurer/linux/enterpriselinux/fedora.go

@@ -15,6 +15,8 @@ type Fedora struct {
 	configurer.Linux
 }
 
+var _ configurer.Configurer = (*Fedora)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {

configurer/linux/enterpriselinux/oracle.go

@@ -13,6 +13,8 @@ type OracleLinux struct {
 	configurer.Linux
 }
 
+var _ configurer.Configurer = (*OracleLinux)(nil)
+
 func init() {
 	registry.RegisterOSModule(
 		func(os rig.OSVersion) bool {