Versions in this module Expand all Collapse all v1 v1.2.1 Feb 28, 2022 Changes in this version + func ReleaseTask(t *Task) + type DbTask struct + Address string + CreatedAt time.Time + DeletedAt *time.Time + ExecTime time.Time + Id uint + Name string + NextExecTime *time.Time + Path string + RetryTimes int + Schema string + Score int64 + Times int + Token string + Type pb.TaskType + Uid string + UpdatedAt time.Time + func (t *DbTask) TableName() string + type MongoTask struct + Address string + Args string + CreatedAt int64 + DeletedAt int64 + ExecTime int64 + Id primitive.ObjectID + Name string + NextExecTime int64 + Path string + RetryTimes int + Schema string + Score int64 + Times int + Token string + Type int32 + Uid string + UpdatedAt int64 + func (mt *MongoTask) Collection() string + func (mt *MongoTask) ConvertTask(cp xcopy.XCopy, t *Task) + type RedisTask map[string]interface + func (rt RedisTask) Args(args *[]interface{}) + type Task struct + Address string + Args string + CreatedAt int64 + DeletedAt int64 + ExecTime int64 + Id string + Name string + NextExecTime int64 + Path string + RetryTimes int + Schema string + Score int64 + Times int + Type int32 + Uid string + UpdatedAt int64 + func GenerateTask() *Task + func (t *Task) ConvertMongoTask(cp xcopy.XCopy, mt *MongoTask) + func (t *Task) ConvertRedisTask() RedisTask + func (t *Task) NextDelayTime() time.Duration v1.1.0-beta Jun 21, 2021