Versions in this module Expand all Collapse all v1 v1.0.0 Dec 17, 2020 Changes in this version + func InstallArchive(ctx context.Context, node string, rawURL string, dest string) error + func IsDaemonRunning(ctx context.Context, node string, cmd string, pidFile string) bool + func IsDir(ctx context.Context, node string, path string) bool + func IsFileExist(ctx context.Context, node string, name string) bool + func IsProcessExist(ctx context.Context, node string, pid int) bool + func KillDaemon(ctx context.Context, node cluster.Node, cmd string, pidFile string) error + func MatchInArray(arr []string, value string) bool + func Mkdir(ctx context.Context, node string, dir string) error + func ReadDir(ctx context.Context, node string, dir string) ([]string, error) + func RemoveDir(ctx context.Context, node string, dir string) error + func StartDaemon(ctx context.Context, node string, opts DaemonOptions, cmd string, ...) error + func StopDaemon(ctx context.Context, node string, cmd string, pidFile string) error + func Wget(ctx context.Context, node string, rawURL string, dest string) (string, error) + func WriteFile(ctx context.Context, node string, file string, data string) error + type BlockRunner struct + func (r *BlockRunner) Init(n int) + func (r *BlockRunner) Run(f func()) + type DaemonOptions struct + ChDir string + NoClose bool + PidFile string + func NewDaemonOptions(chDir string, pidFile string) DaemonOptions