taskqueue

Jan 21, 2015

Changes in this version

+ var ErrTaskAlreadyAdded = errors.New("taskqueue: task has already been added")

+ func Delete(c appengine.Context, task *Task, queueName string) error

+ func DeleteMulti(c appengine.Context, tasks []*Task, queueName string) error

+ func ModifyLease(c appengine.Context, task *Task, queueName string, leaseTime int) error

+ func Purge(c appengine.Context, queueName string) error

+ type QueueStatistics struct

+ EnforcedRate float64

+ Executed1Minute int

+ InFlight int

+ OldestETA time.Time

+ Tasks int

+ func QueueStats(c appengine.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 appengine.Context, task *Task, queueName string) (*Task, error)

+ func AddMulti(c appengine.Context, tasks []*Task, queueName string) ([]*Task, error)

+ func Lease(c appengine.Context, maxTasks int, queueName string, leaseTime int) ([]*Task, error)

+ func LeaseByTag(c appengine.Context, maxTasks int, queueName string, leaseTime int, tag string) ([]*Task, error)

+ func NewPOSTTask(path string, params url.Values) *Task