entity

type Address struct {
	Host string
	Port string
}

type AddressOptions struct {
	Host string
	Port string
}

type OssTask struct {
	Type         int       `json:"type"` //1 by file,2 by io.read
	FilePath     string    `json:"file_path"`
	OssPath      string    `json:"oss_path"`
	FileIOReader io.Reader `json:"file_io_reader"`
}

type Result bson.M

type StreamMessageTaskData struct {
	TaskId  primitive.ObjectID `json:"task_id"`
	Records []interface{}      `json:"data"`
	Logs    []string           `json:"logs"`
}

type TaskMessage struct {
	Id    primitive.ObjectID `json:"id"`
	Key   string             `json:"key"`
	Cmd   string             `json:"cmd"`
	Param string             `json:"param"`
}

type TaskRunOptions struct {
}