autohttp

type DatabaseCallbackInterface interface {
	// 创建初始任务
	CreateTask(c context.Context, item *Item) (err error)
	// 删除任务
	DeleteTask(c context.Context, taskId uint64) (err error)
	// 查询待重试的任务(仅ID)
	IncompleteTaskIdList(c context.Context, currentTime int64) (list []uint64, err error)
	// 待清理任务列表，status表示状态，timestamp表示某个Unix时间点之前
	TaskToCleanList(c context.Context, status uint8, timestamp int64) (list []uint64, err error)
	// 查询任务详细信息
	TaskDetail(c context.Context, taskId uint64) (item Item, err error)
	// 查询任务详细信息
	TaskDetailByBusiness(c context.Context, businessType string, businessId string) (item Item, err error)
	// 更新任务
	UpdateTask(c context.Context, item *Item) (err error)
}

type Item struct {
	ID                  uint64            // 唯一标识ID
	BusinessType        string            // 业务类型，用户自定义
	BusinessId          string            // 业务主键，同一业务类型不能出现重复
	Url                 string            // HTTP请求URL
	Method              string            // HTTP请求方法
	Header              map[string]string // HTTP请求头
	Body                []byte            // HTTP请求Body
	RetryType           bool              // 重试类型
	RetryLadderInterval []int64           // 阶梯性重试的间隔
	RetryStepInterval   int64             // 周期性重试的间隔
	RetryStepTime       int64             // 周期性重试的次数
	RetryCount          int64             // 重试计数
	Status              uint8             // 状态，参见常量StatusXXX
	RequestTime         int64             // 首次发起请求时间，Unix时间戳，单位秒
	LastRetryTime       int64             // 上一次重试的时间，Unix时间戳，单位秒
	NextRetryTime       int64             // 下一次重试时间，Unix时间戳，单位秒
	SuccessTime         int64             // 成功时间，Unix时间戳，单位秒
}

type StatusCallbackInterface interface {
	// 如果要实现发送前修改Item，则复写此方法
	OnTaskBuilding(c context.Context, item *Item)
	// 结果判断
	OnTaskResultValid(c context.Context, item Item, resultBytes []byte) (err error)
	// 更新任务状态
	OnTaskStatusUpdate(c context.Context, item Item)
}