Versions in this module Expand all Collapse all v1 v1.0.0 Jan 28, 2024 Changes in this version + func CleanupComponent(ctx context.Context, delFileMaps map[string]set.StringSet) error + func DeleteGlobalDirs(ctx context.Context, host string, options *spec.GlobalOptions) error + func DeletePublicKey(ctx context.Context, host string) error + func DestroyComponent(ctx context.Context, instances []spec.Instance, cls spec.Topology, ...) error + func DestroyMonitored(ctx context.Context, inst spec.Instance, options *spec.TSMonitoredOptions, ...) error + func Download(prefix, component, nodeOS, arch, version string) error + func EnableComponent(ctx context.Context, instances []spec.Instance, noAgentHosts set.StringSet, ...) error + func EnableMonitored(ctx context.Context, hosts []string, noAgentHosts set.StringSet, ...) error + func FilterComponent(comps []spec.Component, components set.StringSet) (res []spec.Component) + func FilterInstance(instances []spec.Instance, nodes set.StringSet) (res []spec.Instance) + func Restart(ctx context.Context, cluster spec.Topology, options Options, ...) error + func RestartMonitored(ctx context.Context, hosts []string, noAgentHosts set.StringSet, ...) error + func Start(ctx context.Context, cluster spec.Topology, options Options, ...) error + func StartComponent(ctx context.Context, instances []spec.Instance, options Options, ...) error + func StartMonitored(ctx context.Context, hosts []string, noAgentHosts set.StringSet, ...) error + func Stop(ctx context.Context, cluster spec.Topology, options Options) error + func StopComponent(ctx context.Context, instances []spec.Instance, options Options, ...) error + func StopMonitored(ctx context.Context, hosts []string, noAgentHosts set.StringSet, ...) error + func Uninstall(ctx context.Context, cluster spec.Topology, options Options) error + type DownloadOptions struct + Arch string + Os string + Version string + type Downloader interface + Run func() error + func NewGeminiDownloader(ops DownloadOptions) Downloader + type Executor interface + ExecCommand func(ip string, command string) (string, error) + ExecRunAction func(action *RunAction, errChan chan error) string + ExecStopAction func(action *StopAction) (string, error) + func NewGeminiExecutor(clients map[string]*ssh.Client) Executor + type GeminiDownloader struct + Url string + func (d *GeminiDownloader) CleanFile(dir string) + func (d *GeminiDownloader) Run() error + type GeminiExecutor struct + func (e *GeminiExecutor) ExecCommand(ip string, command string) (string, error) + func (e *GeminiExecutor) ExecRunAction(action *RunAction, errChan chan error) string + func (e *GeminiExecutor) ExecStopAction(action *StopAction) (string, error) + type Options struct + APITimeout uint64 + CleanupAuditLog bool + CleanupData bool + CleanupLog bool + Concurrency int + DisplayMode string + Force bool + IgnoreConfigCheck bool + Nodes []string + OptTimeout uint64 + RetainDataNodes []string + RetainDataRoles []string + Roles []string + SSHProxyHost string + SSHProxyIdentity string + SSHProxyPort int + SSHProxyTimeout uint64 + SSHProxyUsePassword bool + SSHProxyUser string + SSHTimeout uint64 + type RunAction struct + Info *RunInfo + Remote *config.RemoteHost + User string + type RunActions struct + MetaAction []*RunAction + SqlAction []*RunAction + StoreAction []*RunAction + type RunInfo struct + Args []string + ScriptPath string + type StopAction struct + ProcessNames []string + Remote *config.RemoteHost