Index: service/taskqueue/types.go |
diff --git a/upstream_types.go b/service/taskqueue/types.go |
similarity index 52% |
rename from upstream_types.go |
rename to service/taskqueue/types.go |
index e6b41bcb3ed49cb8fd11f0addce5a0b768598534..c8cde3996c2f3e96d8568ec529a2cc7b15b21f97 100644 |
--- a/upstream_types.go |
+++ b/service/taskqueue/types.go |
@@ -7,78 +7,19 @@ |
// 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 TQTask.RetryOptions) to |
+// 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 gae |
+package taskqueue |
import ( |
"net/http" |
"time" |
) |
-// DSByteString is a short byte slice (up to 1500 bytes) that can be indexed. |
-type DSByteString []byte |
- |
-// BSKey is a key for a blobstore blob. |
-// |
-// Conceptually, this type belongs in the blobstore package, but it lives in the |
-// appengine package to avoid a circular dependency: blobstore depends on |
-// datastore, and datastore needs to refer to the BSKey type. |
-// |
-// Blobstore is NOT YET supported by gae, but may be supported later. Its |
-// inclusion here is so that the RawDatastore can interact (and round-trip) |
-// correctly with other datastore API implementations. |
-type BSKey string |
- |
-// DSGeoPoint represents a location as latitude/longitude in degrees. |
-// |
-// You probably shouldn't use these, but their inclusion here is so that the |
-// RawDatastore can interact (and round-trip) correctly with other datastore API |
-// implementations. |
-type DSGeoPoint struct { |
- Lat, Lng float64 |
-} |
- |
-// Valid returns whether a DSGeoPoint is within [-90, 90] latitude and [-180, |
-// 180] longitude. |
-func (g DSGeoPoint) Valid() bool { |
- return -90 <= g.Lat && g.Lat <= 90 && -180 <= g.Lng && g.Lng <= 180 |
-} |
- |
-// DSTransactionOptions are the options for running a transaction. |
-type DSTransactionOptions struct { |
- // XG is whether the transaction can cross multiple entity groups. In |
- // comparison, a single group transaction is one where all datastore keys |
- // used have the same root key. Note that cross group transactions do not |
- // have the same behavior as single group transactions. In particular, it |
- // is much more likely to see partially applied transactions in different |
- // entity groups, in global queries. |
- // It is valid to set XG to true even if the transaction is within a |
- // single entity group. |
- XG bool |
- // Attempts controls the number of retries to perform when commits fail |
- // due to a conflicting transaction. If omitted, it defaults to 3. |
- Attempts int |
-} |
- |
-// MCStatistics represents a set of statistics about the memcache cache. This |
-// may include items that have expired but have not yet been removed from the |
-// cache. |
-type MCStatistics struct { |
- Hits uint64 // Counter of cache hits |
- Misses uint64 // Counter of cache misses |
- ByteHits uint64 // Counter of bytes transferred for gets |
- |
- Items uint64 // Items currently in the cache |
- Bytes uint64 // Size of all items currently in the cache |
- |
- Oldest int64 // Age of access of the oldest item, in seconds |
-} |
- |
-// TQStatistics represents statistics about a single task queue. |
-type TQStatistics struct { |
+// 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 |
@@ -87,8 +28,8 @@ type TQStatistics struct { |
EnforcedRate float64 // requests per second |
} |
-// TQRetryOptions let you control whether to retry a task and the backoff intervals between tries. |
-type TQRetryOptions struct { |
+// 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 |
@@ -111,8 +52,8 @@ type TQRetryOptions struct { |
ApplyZeroMaxDoublings bool |
} |
-// TQTask represents a taskqueue task to be executed. |
-type TQTask struct { |
+// Task represents a taskqueue task to be executed. |
+type Task struct { |
// Path is the worker URL for the task. |
// If unset, it will default to /_ah/queue/<queue_name>. |
Path string |
@@ -154,11 +95,5 @@ type TQTask struct { |
Tag string |
// Retry options for this task. May be nil. |
- RetryOptions *TQRetryOptions |
-} |
- |
-// GICertificate represents a public certificate for the app. |
-type GICertificate struct { |
- KeyName string |
- Data []byte // PEM-encoded X.509 certificate |
+ RetryOptions *RetryOptions |
} |