internal

Documentation

Index

• func BuildClients(host string, config *ssh.ClientConfig, num int) []*sftp.Client
• func BuildRemoteFileList(walker *fs.Walker, basepath string) map[string]file
• func CompareTree(basepath string, remoteMap map[string]file, ...) (rmdirs []file, rms []file, mkdirs []file, puts []file)
• func FileSliceToChan(in []file) <-chan file
• func NewSFTPClient(addr string, config *ssh.ClientConfig) (*sftp.Client, error)
• func ProcessDelete(client *sftp.Client, dc <-chan file, dryRun bool, done chan<- bool)
• func ProcessPut(client *sftp.Client, basepath string, pc <-chan file, dryRun bool, ...)

Functions

func BuildClients

func BuildClients(host string, config *ssh.ClientConfig, num int) []*sftp.Client

func BuildRemoteFileList

func BuildRemoteFileList(walker *fs.Walker, basepath string) map[string]file

func CompareTree

func CompareTree(basepath string, remoteMap map[string]file, skipFiles, skipDirs []*regexp.Regexp, appendFile bool) (rmdirs []file, rms []file, mkdirs []file, puts []file)

func FileSliceToChan

func FileSliceToChan(in []file) <-chan file

func NewSFTPClient

func NewSFTPClient(addr string, config *ssh.ClientConfig) (*sftp.Client, error)

func ProcessDelete

func ProcessDelete(client *sftp.Client, dc <-chan file, dryRun bool, done chan<- bool)

func ProcessPut

func ProcessPut(client *sftp.Client, basepath string, pc <-chan file, dryRun bool, done chan<- bool)