transport

Documentation

Index

• type Connection
  • func NewConnection(server *inventory.Server, timeout time.Duration) (Connection, error)
• type ExecCallbackFunc
• type Session
  • func (s *Session) CloseStdin() error
  • func (s *Session) Start(cmd string) error
  • func (s *Session) Stdin() io.Writer

Types

type Connection

type Connection interface {
	Close() error
	Exec(context.Context, bool, ExecCallbackFunc) error
	GetAddress() string
	GetHost() string
	// TODO: Redesign this to avoid mutating state
	SetError(error)
}

func NewConnection

func NewConnection(server *inventory.Server, timeout time.Duration) (Connection, error)

type ExecCallbackFunc

type ExecCallbackFunc func(*Session) (error, *errgroup.Group)

type Session

type Session struct {
	// contains filtered or unexported fields
}

Session is a wrapper around ssh.Session

func (*Session) CloseStdin

func (s *Session) CloseStdin() error

CloseStdin closes the stdin pipe of the remote process

func (*Session) Start

func (s *Session) Start(cmd string) error

Start starts a remote process in the current session

func (*Session) Stdin

func (s *Session) Stdin() io.Writer

Stdin returns a pipe to the stdin of the remote process