uploader

Documentation

Index

• func NewOneTimeUploader(uploaderer_config config.UploaderConfig, tf string)
• func NewUploader(uploaderer_config config.UploaderConfig, tf string)
• type FileLookupObj
• type FileObj
• type FolderScanner
  • func (scanner *FolderScanner) Start(c chan FileObj, done chan int, scan_one_time_only bool)
  • func (scanner *FolderScanner) StartWithWatcher(c chan FileObj, done chan int, scan_one_time_only bool)
  • func (scanner *FolderScanner) Stop()
• type SftpUploader
  • func (uper *SftpUploader) Start(c chan FileObj, done chan int)
  • func (uper *SftpUploader) Stop()

Functions

func NewOneTimeUploader

func NewOneTimeUploader(uploaderer_config config.UploaderConfig, tf string)

func NewUploader

func NewUploader(uploaderer_config config.UploaderConfig, tf string)

Types

type FileLookupObj

type FileLookupObj struct {
	Pass int
	Stat fs.FileInfo
}

type FileObj

type FileObj struct {
	Path string
	Stat fs.FileInfo
}

type FolderScanner

type FolderScanner struct {
	config.UploaderConfig

	Default_sleep_time int
	LocalFolderMap     map[string]FileLookupObj
	// contains filtered or unexported fields
}

func (*FolderScanner) Start

func (scanner *FolderScanner) Start(c chan FileObj, done chan int, scan_one_time_only bool)

func (*FolderScanner) StartWithWatcher

func (scanner *FolderScanner) StartWithWatcher(c chan FileObj, done chan int, scan_one_time_only bool)

func (*FolderScanner) Stop

func (scanner *FolderScanner) Stop()

type SftpUploader

type SftpUploader struct {
	config.UploaderConfig
	// contains filtered or unexported fields
}

func (*SftpUploader) Start

func (uper *SftpUploader) Start(c chan FileObj, done chan int)

func (*SftpUploader) Stop

func (uper *SftpUploader) Stop()