sftp

Documentation

Index

• type Executor
• type FtpAdapter
  • func NewFtp(console *zap.Logger, rabbitAdapter queue.Executor) *FtpAdapter
  • func (s *FtpAdapter) Connection(con *ssh.Client) (*sftp.Client, error)
  • func (s *FtpAdapter) CreateDir(conn *sftp.Client, root string) error
  • func (s *FtpAdapter) CreateFile(conn *sftp.Client) error
  • func (s *FtpAdapter) GetFiles(conn *sftp.Client) error
  • func (s *FtpAdapter) GetRootPath(conn *sftp.Client) error

Types

type Executor

type Executor interface {
	Connection(con *ssh.Client) (*sftp.Client, error)
	GetRootPath(conn *sftp.Client) error
}

type FtpAdapter

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

func NewFtp

func NewFtp(console *zap.Logger, rabbitAdapter queue.Executor) *FtpAdapter

func (*FtpAdapter) Connection

func (s *FtpAdapter) Connection(con *ssh.Client) (*sftp.Client, error)

func (*FtpAdapter) CreateDir

func (s *FtpAdapter) CreateDir(conn *sftp.Client, root string) error

func (*FtpAdapter) CreateFile

func (s *FtpAdapter) CreateFile(conn *sftp.Client) error

func (*FtpAdapter) GetFiles

func (s *FtpAdapter) GetFiles(conn *sftp.Client) error

func (*FtpAdapter) GetRootPath

func (s *FtpAdapter) GetRootPath(conn *sftp.Client) error