batch

type Handler interface {
	ItemsToOperation(func(items []string) (operation Operation, err *data.CodeError)) Handler
	OnResult(func(operationInfo string, operation Operation, result *OperationResult)) Handler
	OnError(func(err *data.CodeError)) Handler
	Start()
}

type Info struct {
	flow.Info
	export.FileExporterConfig

	Overwrite bool // 是否覆盖

	// 工作数据源
	WorkList      []flow.Work // 工作数据源：列表
	InputFile     string      // 工作数据源：文件
	ItemSeparate  string      // 工作数据源：每行元素按分隔符分的分隔符
	MinItemsCount int         // 工作数据源：每行元素最小数量
	EnableStdin   bool        // 工作数据源：stdin, 当 InputFile 不存在时使用 stdin

	MaxOperationCountPerRequest int
}

type Operation interface {
	flow.Work

	ToOperation() (string, *data.CodeError)
}

type OperationCondition struct {
	FileHash string
	FileMime string
	FileSize string
	PutTime  string
}

type OperationCreator interface {
	Create(info string) (work Operation, err *data.CodeError)
}

type OperationResult struct {
	Code     int
	Hash     string `json:"hash"`
	FSize    int64  `json:"fsize"`
	PutTime  int64  `json:"putTime"`
	MimeType string `json:"mimeType"`
	Type     int    `json:"type"`
	Error    string
	Parts    []int64 `json:"parts"`
}