Add 'user friendly' datastore API.

impl/memory/taskqueue_data.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.
 
 package memory
 
 import (
         "errors"
         "fmt"
         "net/http"
         "sync"
         "sync/atomic"
 
         "golang.org/x/net/context"
 
-        rds "github.com/luci/gae/service/rawdatastore"
+        ds "github.com/luci/gae/service/datastore"
         tq "github.com/luci/gae/service/taskqueue"
         "github.com/luci/luci-go/common/clock"
 )
 
 var (
         currentNamespace = http.CanonicalHeaderKey("X-AppEngine-Current-Namespace")
         defaultNamespace = http.CanonicalHeaderKey("X-AppEngine-Default-Namespace")
 )
 
 //////////////////////////////// taskQueueData /////////////////////////////////
@@ skipping 22 matching lines @@
 func (t *taskQueueData) applyTxn(c context.Context, obj memContextObj) {
         txn := obj.(*txnTaskQueueData)
         for qn, tasks := range txn.anony {
                 for _, tsk := range tasks {
                         tsk.Name = mkName(c, tsk.Name, t.named[qn])
                         t.named[qn][tsk.Name] = tsk
                 }
         }
         txn.anony = nil
 }
-func (t *taskQueueData) mkTxn(*rds.TransactionOptions) memContextObj {
+func (t *taskQueueData) mkTxn(*ds.TransactionOptions) memContextObj {
         return &txnTaskQueueData{
                 parent: t,
                 anony:  tq.AnonymousQueueData{},
         }
 }
 
 func (t *taskQueueData) GetTransactionTasks() tq.AnonymousQueueData {
         return nil
 }
 
@@ skipping 113 matching lines @@
         closed int32
         anony  tq.AnonymousQueueData
         parent *taskQueueData
 }
 
 var (
         _ = memContextObj((*txnTaskQueueData)(nil))
         _ = tq.Testable((*txnTaskQueueData)(nil))
 )
 
-func (t *txnTaskQueueData) canApplyTxn(obj memContextObj) bool          { return false }
-func (t *txnTaskQueueData) applyTxn(context.Context, memContextObj)     { panic("impossible") }
-func (t *txnTaskQueueData) mkTxn(*rds.TransactionOptions) memContextObj { panic("impossible") }
+func (t *txnTaskQueueData) canApplyTxn(obj memContextObj) bool         { return false }
+func (t *txnTaskQueueData) applyTxn(context.Context, memContextObj)    { panic("impossible") }
+func (t *txnTaskQueueData) mkTxn(*ds.TransactionOptions) memContextObj { panic("impossible") }
 
 func (t *txnTaskQueueData) endTxn() {
         if atomic.LoadInt32(&t.closed) == 1 {
                 panic("cannot end transaction twice")
         }
         atomic.StoreInt32(&t.closed, 1)
 }
 
 func (t *txnTaskQueueData) run(f func() error) error {
         // Slightly different from the SDK... datastore and taskqueue each implement
@@ skipping 44 matching lines @@
         return t.parent.GetTombstonedTasks()
 }
 
 func (t *txnTaskQueueData) GetScheduledTasks() tq.QueueData {
         return t.parent.GetScheduledTasks()
 }
 
 func (t *txnTaskQueueData) CreateQueue(queueName string) {
         t.parent.CreateQueue(queueName)
 }