Fetch the repository succeeded.
package task
import (
"fmt"
"time"
)
type errNonsupportType struct {
valueType string
}
func NewErrNonsupportType(valueType string) error {
return &errNonsupportType{valueType: valueType}
}
func (e *errNonsupportType) Error() string {
return e.valueType + ":不是支持类型"
}
// ErrRetryTaskLater 重试错误
type ErrRetryTaskLater struct {
msg string
retryIn time.Duration
}
// RetryIn 返回重试时间,从现在开始到执行的间隔
func (e ErrRetryTaskLater) RetryIn() time.Duration {
return e.retryIn
}
// Error 实现标准error接口
func (e ErrRetryTaskLater) Error() string {
return fmt.Sprintf("Task error: %s Will retry in: %s", e.msg, e.retryIn)
}
// NewErrRetryTaskLater 生成重试错误
func NewErrRetryTaskLater(msg string, retryIn time.Duration) ErrRetryTaskLater {
return ErrRetryTaskLater{msg: msg, retryIn: retryIn}
}
type Retrievable interface {
RetryIn() time.Duration
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。