mirror of
https://github.com/kubesphere/kubekey.git
synced 2025-12-26 01:22:51 +00:00
42 lines
901 B
Go
42 lines
901 B
Go
package manager
|
|
|
|
import (
|
|
ssh2 "github.com/pixiake/kubekey/util/ssh"
|
|
"github.com/sirupsen/logrus"
|
|
|
|
kubekeyapi "github.com/pixiake/kubekey/apis/v1alpha1"
|
|
|
|
"github.com/pixiake/kubekey/util/runner"
|
|
//"k8s.io/client-go/rest"
|
|
//bootstraputil "k8s.io/cluster-bootstrap/token/util"
|
|
//dynclient "sigs.k8s.io/manager-runtime/pkg/client"
|
|
)
|
|
|
|
type Manager struct {
|
|
Cluster *kubekeyapi.ClusterCfg
|
|
Logger logrus.FieldLogger
|
|
Connector *ssh2.Dialer
|
|
Runner *runner.Runner
|
|
AllNodes *kubekeyapi.Hosts
|
|
EtcdNodes *kubekeyapi.Hosts
|
|
MasterNodes *kubekeyapi.Hosts
|
|
WorkerNodes *kubekeyapi.Hosts
|
|
K8sNodes *kubekeyapi.Hosts
|
|
WorkDir string
|
|
JoinCommand string
|
|
JoinToken string
|
|
Verbose bool
|
|
}
|
|
|
|
func (mgr *Manager) KubeadmVerboseFlag() string {
|
|
if mgr.Verbose {
|
|
return "--v=6"
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (mgr *Manager) Clone() *Manager {
|
|
newManager := *mgr
|
|
return &newManager
|
|
}
|