run

Jan 4, 2023

Changes in this version

+ func PrefixTemplate(prefix string, data PrefixData) (string, error)

type LocalhostClient

+ Port uint16

+ type PrefixData struct

+ Host string

+ Index int

+ Name string

+ Port uint16

+ User string

+ func (h PrefixData) Style(s any, args ...string) string

Dec 4, 2022

Changes in this version

+ const Continue

+ const No

+ const Yes

+ func CalcForks(batch int, forks uint32) int

+ func CalcFreeForks(batch int, tasks int, forks uint32) int

+ func PrintHeader(value string, ts dao.Text, padding bool)

type Client

+ Connected func() bool

+ type LocalSession struct

type LocalhostClient

+ Sessions []LocalSession

+ func (c *LocalhostClient) Connected() bool

type Run

+ UnreachableServers []dao.Server

+ func (run *Run) ParseTaskTarget(runFlags *core.RunFlags, setRunFlags *core.SetRunFlags)

type SSHClient

+ Sessions []SSHSession

+ func (c *SSHClient) Connected() bool

+ type SSHSession struct

+ type ServerTask struct

+ Cmd *dao.TaskCmd

+ Server *dao.Server

+ Task *dao.Task

+ type TaskOption int

+ func StepTaskExecute(task string, host string, mu *sync.Mutex) (TaskOption, error)

Oct 9, 2022

Changes in this version

+ func FingerprintSHA256(b []byte) string

+ func GetFingerprintPubKey(server dao.Server) (string, error)

+ func GetPasswordIdentitySigner(server dao.Server) (ssh.Signer, error)

+ func GetSigner(server dao.Server) (ssh.Signer, error)

+ type Signers struct

Sep 16, 2022

Changes in this version

type ErrConnect

+ func ParseServers(sshConfigFile *string, servers *[]dao.Server) ([]ErrConnect, error)

Aug 26, 2022

Changes in this version

+ func GetGlobalIdentitySigner(runFlags *core.RunFlags) (ssh.Signer, error)

+ func GetSSHAgentSigners() ([]ssh.Signer, error)

type ErrConnect

+ func GetIdentity(server dao.Server) (ssh.Signer, *ErrConnect)

+ func GetPassworIdentitySigner(server dao.Server) (ssh.Signer, *ErrConnect)

+ func GetPasswordAuth(server dao.Server) (ssh.AuthMethod, *ErrConnect)

+ func (e *ErrConnect) Error() string

type Run

+ func (run *Run) ParseServers() error

Jul 30, 2022

Changes in this version

type Client

+ GetName func() string

type LocalhostClient

+ Name string

+ func (c *LocalhostClient) GetName() string

type SSHClient

+ func (c *SSHClient) GetName() string

Jun 25, 2022

Changes in this version

+ func HeaderTemplate(header string, data HeaderData) (string, error)

+ func Line(addresses []string, key ssh.PublicKey) string

+ type HeaderData struct

+ Desc string

+ Index int

+ Name string

+ NumTasks int

+ func (h HeaderData) Style(s any, args ...string) string

Jun 7, 2022

Changes in this version

+ var DefaultTimeout = 20 * time.Second

+ var ResetColor = "\033[0m"

+ func AddKnownHost(host string, remote net.Addr, key ssh.PublicKey, knownFile string) (err error)

+ func AsExport(env []string) string

+ func CheckKnownHost(host string, remote net.Addr, key ssh.PublicKey, knownFile string) (found bool, err error)

+ func ExecTTY(host string, user string, port uint8, cmd string, envs []string) error

+ func InitAuthMethod(globalIdentityFile string, globalPassword string, identities []Identity) (ssh.AuthMethod, error)

+ func RunTableCmd(t TaskContext, data dao.TableOutput, dataMutex *sync.RWMutex, ...) error

+ func RunTextCmd(t TaskContext, textStyle dao.Text, prefix string, parallel bool, ...) error

+ func SSHToServer(host string, user string, port uint8, disableVerifyHost bool, ...) error

+ func VerifyHost(knownHostsFile string, mu *sync.Mutex, host string, remote net.Addr, ...) error

+ type Client interface

+ Close func() error

+ Connect func(bool, string, *sync.Mutex) *ErrConnect

+ GetHost func() string

+ Prefix func() string

+ Run func([]string, string) error

+ Signal func(os.Signal) error

+ Stderr func() io.Reader

+ Stdin func() io.WriteCloser

+ Stdout func() io.Reader

+ Wait func() error

+ Write func(p []byte) (n int, err error)

+ WriteClose func() error

+ type ErrConnect struct

+ Host string

+ Name string

+ Port uint8

+ Reason string

+ User string

+ type Identity struct

+ IdentityFile *string

+ Password *string

+ type LocalhostClient struct

+ Host string

+ User string

+ func (c *LocalhostClient) Close() error

+ func (c *LocalhostClient) Connect(_ bool, _ string, mu *sync.Mutex) *ErrConnect

+ func (c *LocalhostClient) GetHost() string

+ func (c *LocalhostClient) Prefix() string

+ func (c *LocalhostClient) Run(env []string, cmdStr string) error

+ func (c *LocalhostClient) Signal(sig os.Signal) error

+ func (c *LocalhostClient) Stderr() io.Reader

+ func (c *LocalhostClient) Stdin() io.WriteCloser

+ func (c *LocalhostClient) Stdout() io.Reader

+ func (c *LocalhostClient) Wait() error

+ func (c *LocalhostClient) Write(p []byte) (n int, err error)

+ func (c *LocalhostClient) WriteClose() error

+ type Run struct

+ Config dao.Config

+ LocalClients map[string]Client

+ RemoteClients map[string]Client

+ Servers []dao.Server

+ Task *dao.Task

+ func (run *Run) CheckTaskNoColor()

+ func (run *Run) CleanupClients()

+ func (run *Run) ParseTask(configEnv []string, userArgs []string, runFlags *core.RunFlags, ...) error

+ func (run *Run) RunTask(userArgs []string, runFlags *core.RunFlags, setRunFlags *core.SetRunFlags) error

+ func (run *Run) SetClients(runFlags *core.RunFlags, numChannels int, clientCh chan Client, ...) ([]ErrConnect, error)

+ func (run *Run) Table(dryRun bool) dao.TableOutput

+ func (run *Run) TableWork(rIndex int, dryRun bool, data dao.TableOutput, dataMutex *sync.RWMutex) error

+ func (run *Run) Text(dryRun bool)

+ func (run *Run) TextWork(rIndex int, prefixMaxLen int, dryRun bool) error

+ type SSHClient struct

+ AuthMethod ssh.AuthMethod

+ Host string

+ IdentityFile string

+ Name string

+ Password string

+ Port uint8

+ User string

+ func (c *SSHClient) Close() error

+ func (c *SSHClient) Connect(disableVerifyHost bool, knownHostsFile string, mu *sync.Mutex) *ErrConnect

+ func (c *SSHClient) ConnectWith(dialer SSHDialFunc, disableVerifyHost bool, knownHostsFile string, ...) *ErrConnect

+ func (c *SSHClient) GetHost() string

+ func (c *SSHClient) Prefix() string

+ func (c *SSHClient) Run(env []string, cmdStr string) error

+ func (c *SSHClient) Signal(sig os.Signal) error

+ func (c *SSHClient) Stderr() io.Reader

+ func (c *SSHClient) Stdin() io.WriteCloser

+ func (c *SSHClient) Stdout() io.Reader

+ func (c *SSHClient) Wait() error

+ func (c *SSHClient) Write(p []byte) (n int, err error)

+ func (c *SSHClient) WriteClose() error

+ func (sc *SSHClient) DialThrough(net, addr string, config *ssh.ClientConfig) (*ssh.Client, error)

+ type SSHDialFunc func(net, addr string, config *ssh.ClientConfig) (*ssh.Client, error)

+ type TaskContext struct