client

Documentation

Index

• Constants
• Variables
• type ExecOption
  • func ExecWithArgs(args ...string) ExecOption
  • func ExecWithEnv(key, value string) ExecOption
  • func ExecWithValue(key string, value any) ExecOption
• type ExecOptions
  • func NewExecOptions() *ExecOptions
• type GetOption
  • func GetWithDir(dir bool) GetOption
  • func GetWithTrace(trace IOTraceFn) GetOption
  • func GetWithValue(key string, value any) GetOption
• type GetOptions
  • func NewGetOptions() *GetOptions
• type IClient
• type ICmd
• type IOTrace
• type IOTraceFn
• type PutOption
  • func PutWithDir(dir bool) PutOption
  • func PutWithMkdir(mkdir bool) PutOption
  • func PutWithTrace(trace IOTraceFn) PutOption
  • func PutWithValue(key string, value any) PutOption
• type PutOptions
  • func NewPutOptions() *PutOptions
• type Stat

Constants

const (
	DefaultCacheSize   = 1024 * 1024
	DefaultDialTimeout = time.Second * 15
)

const (
	SSHClient   = "ssh"
	WinRMClient = "winrm"
	GRPCClient  = "grpc"
)

Variables

var (
	ErrConnect       = errors.New("connect error")
	ErrInvalidWrite  = errors.New("invalid write result")
	ErrTimeout       = errors.New("request timeout")
	ErrRequest       = errors.New("request exception")
	ErrNotExists     = errors.New("file does not exist")
	ErrAlreadyExists = errors.New("file already exists")
)

Types

type ExecOption

type ExecOption func(*ExecOptions)

func ExecWithArgs

func ExecWithArgs(args ...string) ExecOption

func ExecWithEnv

func ExecWithEnv(key, value string) ExecOption

func ExecWithValue

func ExecWithValue(key string, value any) ExecOption

ExecWithValue set key-value at options.Context

type ExecOptions

type ExecOptions struct {
	Context context.Context

	Args         []string
	Environments map[string]string
}

func NewExecOptions

func NewExecOptions() *ExecOptions

type GetOption

type GetOption func(*GetOptions)

func GetWithDir

func GetWithDir(dir bool) GetOption

func GetWithTrace

func GetWithTrace(trace IOTraceFn) GetOption

func GetWithValue

func GetWithValue(key string, value any) GetOption

type GetOptions

type GetOptions struct {
	Context context.Context

	Dir       bool
	CacheSize int64
	Trace     IOTraceFn
}

func NewGetOptions

func NewGetOptions() *GetOptions

type IClient

type IClient interface {
	Name() string
	Stat(ctx context.Context, name string) (*Stat, error)
	// ReadFile reads file content from remote connection
	ReadFile(ctx context.Context, name string) ([]byte, error)
	// Get gets io.ReadCloser from remote connection
	Get(ctx context.Context, src, dst string, opts ...GetOption) error
	// Put uploads local file to remote host
	Put(ctx context.Context, src, dst string, opts ...PutOption) error
	// Execute executes a given command on remote host
	Execute(ctx context.Context, shell string, opts ...ExecOption) (ICmd, error)
	// Close closes all remote connections
	Close() error
}

type ICmd

type ICmd interface {
	StdinPipe() (io.WriteCloser, error)
	StdoutPipe() (io.Reader, error)
	StderrPipe() (io.Reader, error)
	Start() error
	Wait() error
	Run() error
	CombinedOutput() ([]byte, error)
	Close() error
}

type IOTrace

type IOTrace struct {
	Name  string
	Src   string
	Dst   string
	Total int64
	Chunk int64
	Speed int64
}

type IOTraceFn

type IOTraceFn func(*IOTrace)

type PutOption

type PutOption func(*PutOptions)

func PutWithDir

func PutWithDir(dir bool) PutOption

func PutWithMkdir

func PutWithMkdir(mkdir bool) PutOption

func PutWithTrace

func PutWithTrace(trace IOTraceFn) PutOption

func PutWithValue

func PutWithValue(key string, value any) PutOption

type PutOptions

type PutOptions struct {
	Context context.Context

	Dir       bool
	Mkdir     bool
	CacheSize int64
	Trace     IOTraceFn
}

func NewPutOptions

func NewPutOptions() *PutOptions

type Stat

type Stat struct {
	Name    string
	IsDir   bool
	Mod     os.FileMode
	ModTime time.Time
	Size    int64
}