pic

type MySQLDialInfo struct {
	DBAddress  string
	DBPort     string
	DBName     string
	DBUsername string
	DBPassword string
}

type MySQLPicTaskPipe struct {
	// contains filtered or unexported fields
}

type PicTaskPipe interface {
	/*ErrorTask
	if errors when process the task, invoke this method
	*/
	ErrorTask(task *Task) error

	/*FinishTask
	if task process finished, invoke this method
	*/
	FinishTask(task *TaskFinished) error

	/*GetTasks
	fetch tasks
	if no available task, return nil, and no error.
	*/
	GetTasks(limit int) ([]*Task, error)

	/*UpsertTask
	insert task to pipe
	*/
	UpsertTask(url string) (*Task, error)
}

type QiniuStorer qiniu.QiniuUploader

type QiniuStorerConf struct {
	AccessKey string
	SecretKey string
	Bucket    string
}

type StorePipeCtx struct {
	StorePipeCtxConfig
	// contains filtered or unexported fields
}

type StorePipeCtxConfig struct {
	Conf_TaskFetchLimit                    int
	Conf_SleepDurationWhenFetchErrorOrNull time.Duration
	Conf_HttpConnectionTryTimes            int
	Conf_HttpTimeout                       time.Duration

	BufLen_tasks, BufLen_fetched, BufLen_errc int
	BufLen_finishQueue, BufLen_errorTaskQueue int

	Cnt_StateFinishTask, Cnt_StateErrorTask, Cnt_StateGetTask int
	Cnt_StateStore, Cnt_StateFetch                            int
}

type Storer interface {
	StorerType() string
	StorerKey() string

	Store(r readsizer.ReadSizer, key string) error
	StoreFile(fn string, key string) error
}

type Task struct {
	Key string
	URL string
}

type TaskFinished struct {
	Task

	NodeType string
	NodeName string
	MIMEInfo string
}