Documentation ¶
Index ¶
- 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
- type Map
- type Task
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EachStrings ¶
func EachStrings(data []string)
func GenerateTaskId ¶
Types ¶
type Task ¶
type Task struct { RedisClient *redis.Client // contains filtered or unexported fields }
func (*Task) GetFailTaskLength ¶
func (*Task) GetFailTaskList ¶
func (*Task) GetNormalTaskLength ¶
func (*Task) GetNormalTaskList ¶
func (*Task) GetSuccessTaskLength ¶
func (*Task) GetSuccessTaskList ¶
func (*Task) TakeFailTask ¶
func (*Task) TakeNormalTask ¶
func (*Task) TakeSuccessTask ¶
Click to show internal directories.
Click to hide internal directories.