Versions in this module Expand all Collapse all v1 v1.0.0 Sep 29, 2016 Changes in this version + var ErrTaskAlreadyAdded = errors.New("taskqueue: task has already been added") + func Delete(c context.Context, task *Task, queueName string) error + func DeleteMulti(c context.Context, tasks []*Task, queueName string) error + func ModifyLease(c context.Context, task *Task, queueName string, leaseTime int) error + func Purge(c context.Context, queueName string) error + type QueueStatistics struct + EnforcedRate float64 + Executed1Minute int + InFlight int + OldestETA time.Time + Tasks int + func QueueStats(c context.Context, queueNames []string) ([]QueueStatistics, error) + type RetryOptions struct + AgeLimit time.Duration + ApplyZeroMaxDoublings bool + MaxBackoff time.Duration + MaxDoublings int32 + MinBackoff time.Duration + RetryLimit int32 + type Task struct + Delay time.Duration + ETA time.Time + Header http.Header + Method string + Name string + Path string + Payload []byte + RetryCount int32 + RetryOptions *RetryOptions + Tag string + func Add(c context.Context, task *Task, queueName string) (*Task, error) + func AddMulti(c context.Context, tasks []*Task, queueName string) ([]*Task, error) + func Lease(c context.Context, maxTasks int, queueName string, leaseTime int) ([]*Task, error) + func LeaseByTag(c context.Context, maxTasks int, queueName string, leaseTime int, tag string) ([]*Task, error) + func NewPOSTTask(path string, params url.Values) *Task
Go to main page