Versions in this module Expand all Collapse all v0 v0.0.6 Aug 5, 2023 v0.0.5 Aug 5, 2023 v0.0.4 Aug 4, 2023 v0.0.3 Aug 4, 2023 v0.0.2 Aug 4, 2023 Changes in this version + func SetClusterSSH(ctx context.Context, topo spec.Topology, deployUser string, sshTimeout uint64, ...) error + func SetSSHKeySet(ctx context.Context, privateKeyPath string, publicKeyPath string) error + type CheckOptions struct + ApplyFix bool + ExistCluster bool + IdentityFile string + Opr *operator.CheckOptions + UsePassword bool + User string + type Cluster struct + Name string + Path string + PrivateKey string + User string + Version string + type ClusterMetaInfo struct + ClusterName string + ClusterType string + ClusterVersion string + DashboardURL string + DeployUser string + SSHType string + TLSCACert string + TLSClientCert string + TLSClientKey string + TLSEnabled bool + type DeployOptions struct + IdentityFile string + IgnoreConfigCheck bool + NoLabels bool + SkipCreateUser bool + UsePassword bool + User string + type DeployerInstance interface + Deploy func(b *task.Builder, srcPath string, deployDir string, version string, name string, ...) + type ExecOptions struct + Command string + Sudo bool + type HostCheckResult struct + Message string + Name string + Node string + Status string + type InstInfo struct + ComponentName string + DataDir string + DeployDir string + Host string + ID string + OsArch string + Port int + Ports string + Role string + Since string + Status string + type JSONOutput struct + ClusterMetaInfo ClusterMetaInfo + InstanceInfos []InstInfo + type Manager struct + func NewManager(sysName string, specManager *spec.SpecManager, bindVersion spec.BindVersion) *Manager + func (m *Manager) CheckCluster(clusterOrTopoName string, opt CheckOptions, gOpt operator.Options) error + func (m *Manager) CleanCluster(name string, gOpt operator.Options, cleanOpt operator.Options, ...) error + func (m *Manager) Deploy(name string, clusterVersion string, topoFile string, opt DeployOptions, ...) error + func (m *Manager) DestroyCluster(name string, gOpt operator.Options, destroyOpt operator.Options, ...) error + func (m *Manager) DestroyTombstone(name string, gOpt operator.Options, skipConfirm bool) error + func (m *Manager) Display(name string, opt operator.Options) error + func (m *Manager) EditConfig(name string, skipConfirm bool) error + func (m *Manager) EnableCluster(name string, gOpt operator.Options, isEnable bool) error + func (m *Manager) Exec(name string, opt ExecOptions, gOpt operator.Options) error + func (m *Manager) GetClusterList() ([]Cluster, error) + func (m *Manager) GetClusterTopology(name string, opt operator.Options) ([]InstInfo, error) + func (m *Manager) ListCluster() error + func (m *Manager) Patch(name string, packagePath string, opt operator.Options, ...) error + func (m *Manager) Reload(name string, gOpt operator.Options, skipRestart, skipConfirm bool) error + func (m *Manager) Rename(name string, opt operator.Options, newName string, skipConfirm bool) error + func (m *Manager) RestartCluster(name string, gOpt operator.Options, skipConfirm bool) error + func (m *Manager) ScaleIn(name string, skipConfirm bool, gOpt operator.Options, ...) error + func (m *Manager) ScaleOut(name string, topoFile string, ...) error + func (m *Manager) StartCluster(name string, gOpt operator.Options, ...) error + func (m *Manager) StopCluster(name string, gOpt operator.Options, skipConfirm bool) error + func (m *Manager) Transfer(name string, opt TransferOptions, gOpt operator.Options) error + func (m *Manager) Upgrade(name string, clusterVersion string, opt operator.Options, ...) error + type TransferOptions struct + Limit int + Local string + Pull bool + Remote string