console

Dec 5, 2024

Changes in this version

+ func NewConsolePortDownError() error

+ func ThrowBadConsolePortException(lastRead []byte) error

+ func ThrowConsoleException(lastRead []byte) error

+ func ThrowConsolePortIsBusyException(lastRead []byte) error

+ func ThrowConsolePortIsLockedException(lastRead []byte) error

+ type BadConsolePortException struct

+ func (e *BadConsolePortException) Error() string

+ type CommandInfoPort interface

+ GetPCLwr func() string

+ GetPort func() int

+ GetSpeed func() int

+ type CommandInfoResult struct

+ func (m CommandInfoResult) GetPCLwr() string

+ func (m CommandInfoResult) GetPort() int

+ func (m CommandInfoResult) GetPortName() string

+ func (m CommandInfoResult) GetSpeed() int

+ type CommandsInfoResult map[string]CommandInfoPort

+ type ConsoleException struct

+ func (e *ConsoleException) Error() string

+ type ConsolePortDownError struct

+ func (e *ConsolePortDownError) Error() string

+ type ConsolePortIsBusyException struct

+ func (e *ConsolePortIsBusyException) Error() string

+ type ConsolePortIsLockedException struct

+ func (m *ConsolePortIsLockedException) Error() string

+ func (m *ConsolePortIsLockedException) Is(target error) bool

+ type Streamer struct

+ func NewStreamer(host, consolePort string, credentials credentials.Credentials, ...) *Streamer

+ func (m *Streamer) CheckConsoleError(readRes streamer.ReadRes) error

+ func (m *Streamer) Close()

+ func (m *Streamer) Cmd(ctx context.Context, str string) (cmd.CmdRes, error)

+ func (m *Streamer) ConsoleCmd(ctx context.Context, command string, sendNewLine bool) ([]byte, error)

+ func (m *Streamer) DiscoveryAllPorts(ctx context.Context) (CommandsInfoResult, error)

+ func (m *Streamer) Download(paths []string, recurse bool) (map[string]streamer.File, error)

+ func (m *Streamer) FlushBuffer()

+ func (m *Streamer) GetBuffer() []byte

+ func (m *Streamer) GetCredentials() credentials.Credentials

+ func (m *Streamer) HasFeature(feature streamer.Const) bool

+ func (m *Streamer) Init(ctx context.Context) error

+ func (m *Streamer) InitAgentForward() error

+ func (m *Streamer) Read(ctx context.Context, size int) ([]byte, error)

+ func (m *Streamer) ReadTo(ctx context.Context, exp expr.Expr) (streamer.ReadRes, error)

+ func (m *Streamer) SendCharacter(ctx context.Context, char byte) ([]byte, error)

+ func (m *Streamer) SetCredentialsInterceptor(inter func(credentials.Credentials) credentials.Credentials)

+ func (m *Streamer) SetReadTimeout(readTimeout time.Duration) time.Duration

+ func (m *Streamer) SetTrace(cb trace.CB)

+ func (m *Streamer) Upload(m2 map[string]streamer.File) error

+ func (m *Streamer) Write(text []byte) error

+ func (m *Streamer) XRead(ctx context.Context, size int, duration time.Duration, expr expr.Expr) (*streamer.ReadXRes, error)

+ type StreamerOption func(*Streamer)

+ func WithConsolePort(port int) StreamerOption

+ func WithForceAttache() StreamerOption

+ func WithHackedSSL() StreamerOption

+ func WithLogger(log *zap.Logger) StreamerOption

+ func WithPort(port int) StreamerOption

+ func WithSSHTunnel(tunnelHost string) StreamerOption

+ func WithSSHTunnelConn(tunnel *sshtunnel.SSHTunnel) StreamerOption

+ func WithSpeed(speed int) StreamerOption

+ func WithTrace(trace trace.CB) StreamerOption