Versions in this module Expand all Collapse all v0 v0.0.1 Aug 26, 2022 Changes in this version + func Datetime() string + func Each(count int, f func()) + func EachStrings(data []string) + func GenerateTaskId() (string, error) + func JSONGet(jsonContext string, key string) gjson.Result + type Config struct + Addr string + DB int + Password string + type Map map[string]interface + func (m Map) GetJSON() (string, error) + type Task struct + RedisClient *redis.Client + func NewTask(ctx context.Context, config Config) (*Task, error) + func (t *Task) GetFailTaskLength() (int64, error) + func (t *Task) GetFailTaskList() ([]string, error) + func (t *Task) GetNormalTaskLength() (int64, error) + func (t *Task) GetNormalTaskList() ([]string, error) + func (t *Task) GetSuccessTaskLength() (int64, error) + func (t *Task) GetSuccessTaskList() ([]string, error) + func (t *Task) PutFailTask(taskId string, data Map) error + func (t *Task) PutNormalTask(taskId string, data Map) error + func (t *Task) PutSuccessTask(taskId string, data Map) error + func (t *Task) TakeFailTask() (Map, error) + func (t *Task) TakeNormalTask() (Map, error) + func (t *Task) TakeSuccessTask() (Map, error)
Go to main page