datastore: Update AllocateIDs to take keys.

filter/txnBuf/ds_txn.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 txnBuf
 
 import (
         ds "github.com/luci/gae/service/datastore"
         "github.com/luci/luci-go/common/errors"
         "golang.org/x/net/context"
@@ skipping 14 matching lines @@
         state    *txnBufState
         haveLock bool
 }
 
 var _ ds.RawInterface = (*dsTxnBuf)(nil)
 
 func (d *dsTxnBuf) DecodeCursor(s string) (ds.Cursor, error) {
         return d.state.parentDS.DecodeCursor(s)
 }
 
-func (d *dsTxnBuf) AllocateIDs(incomplete *ds.Key, n int) (start int64, err error) {
-        return d.state.parentDS.AllocateIDs(incomplete, n)
+func (d *dsTxnBuf) AllocateIDs(keys []*ds.Key, cb ds.PutMultiCB) error {
+        return d.state.parentDS.AllocateIDs(keys, cb)
 }
 
 func (d *dsTxnBuf) GetMulti(keys []*ds.Key, metas ds.MultiMetaGetter, cb ds.GetMultiCB) error {
         return d.state.getMulti(keys, metas, cb, d.haveLock)
 }
 
 func (d *dsTxnBuf) PutMulti(keys []*ds.Key, vals []ds.PropertyMap, cb ds.PutMultiCB) error {
         return d.state.putMulti(keys, vals, cb, d.haveLock)
 }
 
@@ skipping 65 matching lines @@
         if !d.haveLock {
                 d.state.Lock()
                 defer d.state.Unlock()
         }
         return withTxnBuf(d.ic, cb, opts)
 }
 
 func (d *dsTxnBuf) Testable() ds.Testable {
         return d.state.parentDS.Testable()
 }