streamer

type Chmod struct {
	UID int
	GID int
}

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

type Connector interface {
	Init(context.Context) error
	GetCredentials() credentials.Credentials
	SetCredentialsInterceptor(func(credentials.Credentials) credentials.Credentials)
	SetTrace(trace.CB)
	SetReadTimeout(time.Duration) time.Duration
	PrependBuffer([]byte) error
	Close()
	ReadTo(context.Context, expr.Expr) (ReadRes, error)
	Read(ctx context.Context, n int) ([]byte, error)
	Cmd(ctx context.Context, cmd string) (cmd.CmdRes, error)
	Write([]byte) error
	HasFeature(Const) bool
	Download(paths []string, recurse bool) (map[string]File, error)
	Upload(map[string]File) error
	InitAgentForward() error
}

type Const int

type EOFException struct {
	LastRead []byte
}

type File struct {
	Data  []byte
	Mode  *os.FileMode
	Chmod *Chmod
	Err   error
}

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

type GenericReadOption func(*GenericReadConfig)

type ReadRes interface {
	GetBefore() []byte
	GetAfter() []byte
	GetMatchedGroups() map[string][]byte
	GetMatched() []byte
	GetPatternNo() int
	GetUnderlyingRes() ReadRes // may be nil
}

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

type ReadTimeoutException struct {
	LastRead []byte
	Cause    error
}

type ReadXRes struct {
	RetType   ReadXType
	ExprRes   ReadRes
	BytesRes  []byte
	ExprAfter []byte
}

type ReadXType int64