batch

type Handler interface {
	EmptyOperation(emptyOperation func() flow.Work) Handler
	SetFileExport(exporter *export.FileExporter) Handler
	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

	EnableRecord                bool // 是否开启 record
	RecordRedoWhileError        bool // 重新执行任务时，如果任务已执行但是失败，则再重新执行一次。
	MaxOperationCountPerRequest int
}

type Metric struct {
	Duration     int64 `json:"duration"`
	TotalCount   int64 `json:"total_count"`
	CurrentCount int64 `json:"-"`
	SuccessCount int64 `json:"success_count"`
	FailureCount int64 `json:"failure_count"`
	SkippedCount int64 `json:"skipped_count"`
	// contains filtered or unexported fields
}

type Operation interface {
	flow.Work

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

type OperationCondition struct {
	FileHash string `json:"file_hash"`
	FileMime string `json:"file_mime"`
	FileSize string `json:"file_size"`
	PutTime  string `json:"put_time"`
}

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

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