service/taskqueue: Add NewPOSTTask, remove NewTask

service/taskqueue/task.go

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
-// This file contains types which are mirrors/duplicates of the upstream SDK
-// types. This exists so that users can depend solely on this wrapper library
-// without necessarially needing an SDK implementation present.
-//
-// This was done (instead of type-aliasing from the github version of the SDK)
-// because some of the types need to be tweaked (like Task.RetryOptions) to
-// interact well with the wrapper, and the inconsistency of having some types
-// defined by the gae package and others defined by the SDK was pretty awkward.
-
 package taskqueue
 
 import (
         "net/http"
+        "net/url"
         "time"
 )
 
-// Statistics represents statistics about a single task queue.
-type Statistics struct {
-        Tasks     int       // may be an approximation
-        OldestETA time.Time // zero if there are no pending tasks
-
-        Executed1Minute int     // tasks executed in the last minute
-        InFlight        int     // tasks executing now
-        EnforcedRate    float64 // requests per second
-}
-
 // RetryOptions let you control whether to retry a task and the backoff intervals between tries.
 type RetryOptions struct {
         // Number of tries/leases after which the task fails permanently and is deleted.
         // If AgeLimit is also set, both limits must be exceeded for the task to fail permanently.
         RetryLimit int32
 
         // Maximum time allowed since the task's first try before the task fails permanently and is deleted (only for push tasks).
         // If RetryLimit is also set, both limits must be exceeded for the task to fail permanently.
         AgeLimit time.Duration
 
@@ skipping 50 matching lines @@
         // The number of times the task has been dispatched or leased.
         RetryCount int32
 
         // Tag for the task. Only used when Method is PULL.
         Tag string
 
         // Retry options for this task. May be nil.
         RetryOptions *RetryOptions
 }
 
+// NewPOSTTask creates a Task that will POST to a path with URL-encoded values.
+func NewPOSTTask(path string, params url.Values) *Task {
+        h := make(http.Header)
+        h.Set("Content-Type", "application/x-www-form-urlencoded")
+        return &Task{
+                Path:    path,
+                Payload: []byte(params.Encode()),
+                Header:  h,
+                Method:  "POST",
+        }
+}
+
 // Duplicate returns a deep copy of this Task.
 func (t *Task) Duplicate() *Task {
         ret := *t
 
         if len(t.Header) > 0 {
                 ret.Header = make(http.Header, len(t.Header))
                 for k, vs := range t.Header {
                         newVs := make([]string, len(vs))
                         copy(newVs, vs)
                         ret.Header[k] = newVs
                 }
         }
 
         if len(t.Payload) > 0 {
                 ret.Payload = make([]byte, len(t.Payload))
                 copy(ret.Payload, t.Payload)
         }
 
         if t.RetryOptions != nil {
                 ret.RetryOptions = &RetryOptions{}
                 *ret.RetryOptions = *t.RetryOptions
         }
 
         return &ret
 }