downloader

Documentation

Index

• func NewDownloader(downloader_config config.DownloaderConfig, tf string)
• func NewOneTimeDownloader(downloader_config config.DownloaderConfig, tf string)
• type FileObj
• type SftpDownloader
  • func (dler *SftpDownloader) Start(c chan FileObj, done chan int)
  • func (dler *SftpDownloader) Stop()
• type SftpScanner
  • func (scanner *SftpScanner) Start(c chan FileObj, done chan int, scan_one_time_only bool)
  • func (scanner *SftpScanner) Stop()

Functions

func NewDownloader

func NewDownloader(downloader_config config.DownloaderConfig, tf string)

func NewOneTimeDownloader

func NewOneTimeDownloader(downloader_config config.DownloaderConfig, tf string)

Types

type FileObj

type FileObj struct {
	Path string
	Stat fs.FileInfo
}

type SftpDownloader

type SftpDownloader struct {
	config.DownloaderConfig
	// contains filtered or unexported fields
}

func (*SftpDownloader) Start

func (dler *SftpDownloader) Start(c chan FileObj, done chan int)

func (*SftpDownloader) Stop

func (dler *SftpDownloader) Stop()

type SftpScanner

type SftpScanner struct {
	config.DownloaderConfig

	Default_sleep_time int
	// contains filtered or unexported fields
}

func (*SftpScanner) Start

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

func (*SftpScanner) Stop

func (scanner *SftpScanner) Stop()