sftplibs

Documentation

Index

• func CalculateTimeout(throughput int64, size int64, max_timeout int64) int64
• func ConnectSftpServer(host_ip string, host_port int, user string, password string, keyfile string, ...) (*ssh.Client, *sftp.Client, error)
• func CopyWithCancel(ctx context.Context, dst io.Writer, src io.Reader) (int64, error)
• func DownloadToTemp(ctx context.Context, temp_folder string, source io.Reader, prefix string) (int64, string, error)
• func IncrTempIndex()
• func RenameTempfile(tempfile_path string, output_file string) error

Functions

func CalculateTimeout

func CalculateTimeout(throughput int64, size int64, max_timeout int64) int64

func ConnectSftpServer

func ConnectSftpServer(host_ip string, host_port int, user string, password string, keyfile string, certfile string) (*ssh.Client, *sftp.Client, error)

func CopyWithCancel

func CopyWithCancel(ctx context.Context, dst io.Writer, src io.Reader) (int64, error)

slightly modified function signature: - context has been added in order to propagate cancelation

func DownloadToTemp

func DownloadToTemp(ctx context.Context, temp_folder string, source io.Reader, prefix string) (int64, string, error)

func IncrTempIndex

func IncrTempIndex()

func RenameTempfile

func RenameTempfile(tempfile_path string, output_file string) error