telnet

Documentation

Overview

Package telnet implements telnet transport at very basic level.

Index

• Constants
• type Streamer
  • func NewStreamer(host string, credentials credentials.Credentials, opts ...StreamerOption) *Streamer
  • func (m *Streamer) Close()
  • func (m *Streamer) Cmd(context.Context, string) (gcmd.CmdRes, error)
  • func (m *Streamer) Download(paths []string, recurse bool) (map[string]streamer.File, error)
  • 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(context.Context, int) ([]byte, error)
  • func (m *Streamer) ReadTo(ctx context.Context, expr expr.Expr) (streamer.ReadRes, error)
  • func (m *Streamer) SetCredentialsInterceptor(inter func(credentials.Credentials) credentials.Credentials)
  • func (m *Streamer) SetReadTimeout(duration 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
• type StreamerOption
  • func WithLogger(log *zap.Logger) StreamerOption
  • func WithTrace(trace trace.CB) StreamerOption

Constants

const (
	IAC  = "\xff"
	BIAC = 255

	SB  = "\xfa"
	BSB = 250
	SE  = "\xf0"
	BSE = 240

	WILL  = "\xfb"
	BWILL = 251
	WONT  = "\xfc"
	BWONT = 252
	DO    = "\xfd"
	BDO   = 253
	DONT  = "\xfe"
	BDONT = 254

	BINARY  = "\x00"
	BBINARY = 0
	ECHO    = "\x01"
	BECHO   = 1
	SGA     = "\x03"
	BSGA    = 03
)

Types

type Streamer

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

func NewStreamer

func NewStreamer(host string, credentials credentials.Credentials, opts ...StreamerOption) *Streamer

func (*Streamer) Close

func (m *Streamer) Close()

func (*Streamer) Cmd

func (m *Streamer) Cmd(context.Context, string) (gcmd.CmdRes, error)

func (*Streamer) Download

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

func (*Streamer) GetCredentials

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

func (Streamer) HasFeature

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

func (*Streamer) Init

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

func (*Streamer) InitAgentForward

func (m *Streamer) InitAgentForward() error

func (*Streamer) Read

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

func (*Streamer) ReadTo

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

func (*Streamer) SetCredentialsInterceptor

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

func (*Streamer) SetReadTimeout

func (m *Streamer) SetReadTimeout(duration time.Duration) time.Duration

func (*Streamer) SetTrace

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

func (*Streamer) Upload

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

func (*Streamer) Write

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

type StreamerOption

type StreamerOption func(*Streamer)

func WithLogger

func WithLogger(log *zap.Logger) StreamerOption

func WithTrace

func WithTrace(trace trace.CB) StreamerOption