Versions in this module Expand all Collapse all v0 v0.1.0 Dec 14, 2023 Changes in this version + func GetConfigPEM(user, keyFile string) (*ssh.ClientConfig, error) + func GetConfigUserPass(user, password string) *ssh.ClientConfig + func SetClientsShardNumber(n int) + type ClientOption func(c *clientAttr) + func DisableRequestPty() ClientOption + func RequestPty(term string, h, w uint, modes ssh.TerminalModes) ClientOption + func SetLabels(labels map[string]string) ClientOption + func SetMaxSessions(n int) ClientOption + type MaxSessionsError struct + type Response struct + func (r *Response) Err() error + func (r *Response) ExitStatus() int + func (r *Response) GetStream() *Stream + func (r *Response) GetText(v *VSSH) (string, string, error) + func (r *Response) ID() string + type RunOption func(q *query) + func SetLimitReaderStderr(n int64) RunOption + func SetLimitReaderStdout(n int64) RunOption + type Stream struct + func (s *Stream) BytesStderr() []byte + func (s *Stream) BytesStdout() []byte + func (s *Stream) Close() error + func (s *Stream) Err() error + func (s *Stream) Input(in io.Reader) + func (s *Stream) ScanStderr() bool + func (s *Stream) ScanStdout() bool + func (s *Stream) Signal(sig ssh.Signal) + func (s *Stream) TextStderr() string + func (s *Stream) TextStdout() string + type TimeoutError struct + type VSSH struct + func New() *VSSH + func (v *VSSH) AddClient(addr string, config *ssh.ClientConfig, opts ...ClientOption) error + func (v *VSSH) CurrentProc() uint64 + func (v *VSSH) DecreaseProc(n ...int) + func (v *VSSH) ForceReConn(addr string) error + func (v *VSSH) IncreaseProc(n ...int) + func (v *VSSH) OnDemand() *VSSH + func (v *VSSH) Run(ctx context.Context, cmd string, timeout time.Duration, opts ...RunOption) chan *Response + func (v *VSSH) RunWithLabel(ctx context.Context, cmd, queryStmt string, timeout time.Duration, ...) (chan *Response, error) + func (v *VSSH) SetInitNumProc(n int) + func (v *VSSH) SetLogger(l *log.Logger) + func (v *VSSH) Start() *VSSH + func (v *VSSH) StartWithContext(ctx context.Context) *VSSH + func (v *VSSH) Wait(p ...int) (float64, error)