sshwctl

package

Go to main page

Versions in this module

v1

v1.10.3

Mar 24, 2021

v1.10.2

Mar 12, 2021

v1.10.1

Sep 17, 2020

v1.10.0

Jul 2, 2020

Changes in this version

+ var SshPath = path.Join(homeDir, ".ssh/config")

+ var SshwDir = path.Join(homeDir, ".config/sshw")

+ var SshwGlobalConfigPath = path.Join(SshwDir, "config.yaml")

+ func InitConfig(config interface{}) error

+ func InitNodes(nodes []*Node) error

+ func InitNodesBaseOnGlobal(nodes []*Node, matchFunc MatchFunc)

+ func InitSshNodes(nodes []*Node) error

+ func MatchCommonConfig(node *Node, globalNode *Node) bool

+ func MatchSshConfig(node *Node, globalNode *Node) bool

+ func MergeSshConfig(nodes []*Node, sshNodes []*Node) error

+ type ConfigLoader interface

+ Decode func(nodes *[]*Node) error

+ func NewSshConfigLoader(r io.Reader) ConfigLoader

+ func NewYamlConfigLoader(bs []byte) ConfigLoader

+ type MatchFunc func(node *Node, globalNode *Node) bool

type Node

+ func LoadYamlConfig0(bs []byte) ([]*Node, error)

type NodeCp

+ IsReceive bool

+ type SshConfigLoader struct

+ func (s *SshConfigLoader) Decode(nodes *[]*Node) error

+ type YamlConfigLoader struct

+ func (y *YamlConfigLoader) Decode(nodes *[]*Node) error

v1.10.0-alpha.2

May 14, 2020

v1.10.0-alpha.1

May 6, 2020

v1.10.0-alpha

May 4, 2020

v1.9.3

Apr 21, 2020

Changes in this version

+ func IsEAGAIN(err error) bool

+ type NonblockReader struct

+ CancelFunc context.CancelFunc

+ Ctx context.Context

+ R *os.File

+ func NewNonblockReader(r *os.File) (*NonblockReader, error)

+ func (n2 *NonblockReader) Close() error

+ func (n2 *NonblockReader) Read(p []byte) (n int, err error)

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

+ func (r ReaderFunc) Read(p []byte) (n int, err error)

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

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

v1.9.2

Apr 15, 2020

Changes in this version

type WriteCounter

+ W io.Writer

v1.9.1

Apr 13, 2020

Changes in this version

+ func ReadConfigBytes(filename string) (string, []byte, error)

+ func ReadDefaultConfigBytes(names ...string) (string, []byte, error)

v1.9.0

Mar 29, 2020

Changes in this version

+ func Shell() string

v1.8.3

Mar 24, 2020

v1.8.2

Mar 22, 2020

Changes in this version

+ const KeyAgent

+ const KeyCallback

+ const OnStderr

+ const OnStdout

+ const PostInitClientConfig

+ const PostNewSession

+ const PostSSHDial

+ const PostShell

+ func AgentPostInitClientConfig(ctx *EventContext, clientConfig *ssh.ClientConfig)

+ func AgentPostNewSession(ctx *EventContext, session *ssh.Session) error

+ func AgentPostSSHDial(ctx *EventContext, client *ssh.Client) error

+ func AuthPemPostInitClientConfig(ctx *EventContext, clientConfig *ssh.ClientConfig)

+ func AuthPwdPostInitClientConfig(ctx *EventContext, clientConfig *ssh.ClientConfig)

+ func CallbackOnStdout(ctx *EventContext, line []byte) error

+ func CallbackPostShell(ctx *EventContext, stdin io.WriteCloser) error

+ func IOOnStderr(ctx *EventContext, bytes []byte) error

+ func IOOnStdout(ctx *EventContext, bytes []byte) error

+ type CallbackInfo struct

+ Index int

+ IsError bool

+ Mutex *sync.Mutex

+ func NewCallbackInfo() *CallbackInfo

+ type EventContext struct

+ Attachment map[string]interface{}

+ Node *Node

+ func NewEventContext(node *Node) *EventContext

+ func (e *EventContext) Get(key string) (interface{}, bool)

+ func (e *EventContext) Put(key string, value interface{})

type Node

+ func LoadConfig(bs []byte) ([]*Node, error)

v1.8.1

Mar 20, 2020

Changes in this version

+ func AutoSSHAgent() error

+ func UserIdRsaIsNotExist() bool

type Client

+ RecoverTerminal func()

v1.8.0

Mar 2, 2020

Changes in this version

+ const ApplicationName

+ const TypeParam

+ const TypeStr

+ const WalkIndexFlag

+ const WalkOtherFlag

+ var DefaultCiphers = []string

+ var ErrorInterrupt = errors.New("interrupt")

+ func AbsPath(p string) string

+ func ExecNode(node *Node) error

+ func ExtractBinary(name string, needClose bool) (*os.File, error)

+ func FieldEmpty(t reflect.Type, v reflect.Value) bool

+ func FieldsNotEmpty(v interface{}, ignoreKeys []string) ([]string, error)

+ func IsBookmark(n *Node) bool

+ func LoadConfigBytes(names ...string) (string, []byte, error)

+ func MergeNodes(dstPtr *[]*Node, src []*Node)

+ func PrepareConfig(config interface{}) error

+ func RegisterLifecycle(lifecycle Lifecycle)

+ func WalkInterface(v reflect.Value, walked bool, solver ValueSolver) error

+ type Client interface

+ CanConnect func() bool

+ Close func() error

+ Connect func() error

+ ExecsPost func() error

+ ExecsPre func() error

+ GetClient func() *ssh.Client

+ InitTerminal func() error

+ Ping func() error

+ Scp func() error

+ SetClient func(client *ssh.Client)

+ Shell func() error

+ WatchWindowChange func(windowChange func(ch, cw int) error)

+ func NewClient(node *Node) Client

+ type CommonLifecycle struct

+ Name string

+ OnStderrFunc func(node *Node, line []byte) error

+ OnStdoutFunc func(node *Node, line []byte) error

+ PostInitClientConfigFunc func(node *Node, clientConfig *ssh.ClientConfig) error

+ PostNewSessionFunc func(node *Node, session *ssh.Session) error

+ PostSSHDialFunc func(node *Node, client *ssh.Client) error

+ PostSessionWaitFunc func(node *Node) error

+ PostShellFunc func(node *Node, stdin io.WriteCloser) error

+ PriorityFunc func() int

+ func (d *CommonLifecycle) OnStderr(node *Node, line []byte) error

+ func (d *CommonLifecycle) OnStdout(node *Node, line []byte) error

+ func (d *CommonLifecycle) PostInitClientConfig(node *Node, clientConfig *ssh.ClientConfig) error

+ func (d *CommonLifecycle) PostNewSession(node *Node, session *ssh.Session) error

+ func (d *CommonLifecycle) PostSSHDial(node *Node, client *ssh.Client) error

+ func (d *CommonLifecycle) PostSessionWait(node *Node) error

+ func (d *CommonLifecycle) PostShell(node *Node, stdin io.WriteCloser) error

+ func (d *CommonLifecycle) Priority() int

+ type CustomTemplate struct

+ Templates []*TemplateNode

+ func ParseSshwTemplate(src string) *CustomTemplate

+ func (c *CustomTemplate) Execute() string

+ type GithubRepository struct

+ Name string

+ Url string

+ Username string

+ func (g *GithubRepository) Download(versionMeta *VersionMeta) (*os.File, error)

+ func (g *GithubRepository) LatestVersion() (*VersionMeta, error)

+ type KeyboardInteractive struct

+ Answer string

+ GoogleAuth bool

+ Question string

+ type Lifecycle interface

+ OnStderr func(node *Node, line []byte) error

+ OnStdout func(node *Node, line []byte) error

+ PostInitClientConfig func(node *Node, clientConfig *ssh.ClientConfig) error

+ PostNewSession func(node *Node, session *ssh.Session) error

+ PostSSHDial func(node *Node, client *ssh.Client) error

+ PostSessionWait func(node *Node) error

+ PostShell func(node *Node, stdin io.WriteCloser) error

+ Priority func() int

+ type LifecycleAgent struct

+ func (l *LifecycleAgent) PostInitClientConfig(node *Node, clientConfig *ssh.ClientConfig) error

+ func (l *LifecycleAgent) PostNewSession(node *Node, session *ssh.Session) error

+ func (l *LifecycleAgent) PostSSHDial(node *Node, client *ssh.Client) error

+ func (l *LifecycleAgent) Priority() int

+ type LifecycleCallback struct

+ Cond *sync.Cond

+ Index int

+ IsError bool

+ Mutex *sync.Mutex

+ func (l *LifecycleCallback) OnStdout(node *Node, line []byte) error

+ func (l *LifecycleCallback) PostShell(node *Node, stdin io.WriteCloser) error

+ type LifecycleComposite struct

+ func NewLifeCycleComposite() *LifecycleComposite

+ func (l *LifecycleComposite) OnStderr(node *Node, line []byte) error

+ func (l *LifecycleComposite) OnStdout(node *Node, line []byte) error

+ func (l *LifecycleComposite) PostInitClientConfig(node *Node, clientConfig *ssh.ClientConfig) error

+ func (l *LifecycleComposite) PostNewSession(node *Node, session *ssh.Session) error

+ func (l *LifecycleComposite) PostSSHDial(node *Node, client *ssh.Client) error

+ func (l *LifecycleComposite) PostSessionWait(node *Node) error

+ func (l *LifecycleComposite) PostShell(node *Node, stdin io.WriteCloser) error

+ func (l *LifecycleComposite) Priority() int

+ type LifecycleIO struct

+ func (*LifecycleIO) OnStderr(node *Node, bytes []byte) error

+ func (*LifecycleIO) OnStdout(node *Node, bytes []byte) error

+ func (*LifecycleIO) Priority() int

+ type LifecyclePassword struct

+ func (*LifecyclePassword) PostInitClientConfig(node *Node, clientConfig *ssh.ClientConfig) error

+ type LifecyclePem struct

+ func (*LifecyclePem) PostInitClientConfig(node *Node, clientConfig *ssh.ClientConfig) error

+ type LifecycleQueue []Lifecycle

+ func (l *LifecycleQueue) Len() int

+ func (l *LifecycleQueue) Less(i, j int) bool

+ func (l *LifecycleQueue) Pop() interface{}

+ func (l *LifecycleQueue) Push(x interface{})

+ func (l *LifecycleQueue) Swap(i, j int)

+ type Node struct

+ Alias string

+ CallbackShells []*NodeCallbackShell

+ Children []*Node

+ ControlMaster *bool

+ ExecsPre []*NodeExec

+ ExecsStop []*NodeExec

+ Height int

+ Host string

+ Jump []*Node

+ KeyPath string

+ KeyboardInteractions []KeyboardInteractive

+ MergeIgnore bool

+ Name string

+ Passphrase string

+ Password string

+ Port int

+ Scps []*NodeCp

+ Session *ssh.Session

+ State *terminal.State

+ Stderr io.Writer

+ Stdin io.Reader

+ Stdout io.Writer

+ User string

+ Width int

+ func LoadSshConfig() ([]*Node, error)

+ func LoadYamlConfig(filename string) (string, []*Node, error)

+ func (n *Node) Error(err error)

+ func (n *Node) Print(message string)

+ func (n *Node) Println(message string)

+ func (n *Node) String() string

+ type NodeCallbackShell struct

+ Cmd string

+ CpShell NodeCp

+ Delay time.Duration

+ ErrorPattern string

+ Wait time.Duration

+ type NodeCp struct

+ Src string

+ Tgt string

+ Timeout int64

+ type NodeExec struct

+ Cmd string

+ Var string

+ type Repository interface

+ Download func(versionMeta *VersionMeta) (*os.File, error)

+ LatestVersion func() (*VersionMeta, error)

+ type Response struct

+ Message string

+ Type ResponseType

+ func ParseResponse(reader io.Reader) (Response, error)

+ func (r *Response) GetMessage() string

+ func (r *Response) IsError() bool

+ func (r *Response) IsFailure() bool

+ func (r *Response) IsOk() bool

+ func (r *Response) IsWarning() bool

+ type ResponseType = uint8

+ const Error

+ const Ok

+ const Warning

+ type RuntimeSystem struct

+ GOARCH string

+ GOARCHAlias string

+ GOOS string

+ GOOSAlias string

+ type TemplateNode struct

+ Type string

+ Value string

+ func NewParamNode(v string) *TemplateNode

+ func NewStrNode(v string) *TemplateNode

+ type ValueSolver func(k string, t reflect.Type, v reflect.Value, structField *reflect.StructField) (skipSearch bool)

+ type VersionMeta struct

+ Filename string

+ Version string

+ type WriteCounter struct

+ ProgressTemplate string

+ Total uint64

+ func NewWriteCounter() *WriteCounter

+ func (wc *WriteCounter) Write(p []byte) (int, error)

+ func (wc WriteCounter) PrintProgress()

v1.8.0-alpha

Mar 1, 2020

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL