loader

Documentation

Index

• func Register(key string, cfg *commonconfig.DownloaderConfig, factory CreateFunc, ...) bool
• type CreateFunc
• type ITable
  • func GetTable(key string) ITable
• type Job
• type Manager
• type ReleaseFunc
• type Status

Functions

func Register

func Register(key string, cfg *commonconfig.DownloaderConfig,
	factory CreateFunc, release ReleaseFunc,
	createParams, releaseParams interface{}) bool

Register 注册任务

Types

type CreateFunc

type CreateFunc func(dataPath string, params interface{}) ITable

type ITable

type ITable interface{}

func GetTable

func GetTable(key string) ITable

type Job

type Job struct {
	Key            string
	Finder         finder.IFinder
	Interval       int
	IterCount      int64
	DownloadConfig *commonconfig.DownloaderConfig
}

type Manager

type Manager struct {
	Locker   *sync.RWMutex
	TableMap map[string]ITable
	JobMap   map[string]*Job
}

var ManagerImp *Manager

type ReleaseFunc

type ReleaseFunc func(ITable, interface{})

type Status

type Status int

const (
	DownloadOK Status = iota + 1
	RemoteFileError
	LocalFileIsNewest
	DownloadFileError
	WriteLocalETagError
)