| Index: impl/memory/plist.go
|
| diff --git a/impl/memory/plist.go b/impl/memory/plist.go
|
| index 62e1d7c15bb966cd2f197370b2e42ca6c229aa4f..879258316e9cb7ed309d8d96086aed267a609a82 100644
|
| --- a/impl/memory/plist.go
|
| +++ b/impl/memory/plist.go
|
| @@ -9,7 +9,7 @@ import (
|
| "fmt"
|
| "sort"
|
|
|
| - rds "github.com/luci/gae/service/rawdatastore"
|
| + ds "github.com/luci/gae/service/datastore"
|
| "github.com/luci/gkvlite"
|
| )
|
|
|
| @@ -21,13 +21,13 @@ func (s qIndexSlice) Len() int { return len(s) }
|
| func (s qIndexSlice) Swap(i, j int) { s[i], s[j] = s[j], s[i] }
|
| func (s qIndexSlice) Less(i, j int) bool { return s[i].Less(s[j]) }
|
|
|
| -func defaultIndicies(kind string, pmap rds.PropertyMap) []*qIndex {
|
| +func defaultIndicies(kind string, pmap ds.PropertyMap) []*qIndex {
|
| ret := make(qIndexSlice, 0, 2*len(pmap)+1)
|
| ret = append(ret, &qIndex{kind, false, nil})
|
| for name, pvals := range pmap {
|
| needsIndex := false
|
| for _, v := range pvals {
|
| - if v.IndexSetting() == rds.ShouldIndex {
|
| + if v.IndexSetting() == ds.ShouldIndex {
|
| needsIndex = true
|
| break
|
| }
|
| @@ -44,7 +44,7 @@ func defaultIndicies(kind string, pmap rds.PropertyMap) []*qIndex {
|
| return ret
|
| }
|
|
|
| -func indexEntriesWithBuiltins(k rds.Key, pm rds.PropertyMap, complexIdxs []*qIndex) *memStore {
|
| +func indexEntriesWithBuiltins(k ds.Key, pm ds.PropertyMap, complexIdxs []*qIndex) *memStore {
|
| sip := partiallySerialize(pm)
|
| return sip.indexEntries(k, append(defaultIndicies(k.Kind(), pm), complexIdxs...))
|
| }
|
| @@ -59,7 +59,7 @@ func (s serializedPvals) Less(i, j int) bool { return bytes.Compare(s[i], s[j])
|
| // prop name -> [<serialized DSProperty>, ...]
|
| type serializedIndexablePmap map[string]serializedPvals
|
|
|
| -func partiallySerialize(pm rds.PropertyMap) (ret serializedIndexablePmap) {
|
| +func partiallySerialize(pm ds.PropertyMap) (ret serializedIndexablePmap) {
|
| if len(pm) == 0 {
|
| return
|
| }
|
| @@ -69,11 +69,11 @@ func partiallySerialize(pm rds.PropertyMap) (ret serializedIndexablePmap) {
|
| for k, vals := range pm {
|
| newVals := make(serializedPvals, 0, len(vals))
|
| for _, v := range vals {
|
| - if v.IndexSetting() == rds.NoIndex {
|
| + if v.IndexSetting() == ds.NoIndex {
|
| continue
|
| }
|
| buf.Reset()
|
| - v.Write(buf, rds.WithoutContext)
|
| + v.Write(buf, ds.WithoutContext)
|
| newVal := make([]byte, buf.Len())
|
| copy(newVal, buf.Bytes())
|
| newVals = append(newVals, newVal)
|
| @@ -175,7 +175,7 @@ func (m *matcher) match(idx *qIndex, sip serializedIndexablePmap) (indexRowGen,
|
| return m.buf, true
|
| }
|
|
|
| -func (sip serializedIndexablePmap) indexEntries(k rds.Key, idxs []*qIndex) *memStore {
|
| +func (sip serializedIndexablePmap) indexEntries(k ds.Key, idxs []*qIndex) *memStore {
|
| ret := newMemStore()
|
| idxColl := ret.SetCollection("idx", nil)
|
| // getIdxEnts retrieves an index collection or adds it if it's not there.
|
| @@ -188,7 +188,7 @@ func (sip serializedIndexablePmap) indexEntries(k rds.Key, idxs []*qIndex) *memS
|
| }
|
|
|
| buf := &bytes.Buffer{}
|
| - rds.WriteKey(buf, rds.WithoutContext, k)
|
| + ds.WriteKey(buf, ds.WithoutContext, k)
|
| keyData := buf.Bytes()
|
|
|
| walkPermutations := func(prefix []byte, irg indexRowGen, ents *memCollection) {
|
| @@ -212,7 +212,7 @@ func (sip serializedIndexablePmap) indexEntries(k rds.Key, idxs []*qIndex) *memS
|
| } else if idx.ancestor {
|
| for ancKey := k; ancKey != nil; ancKey = ancKey.Parent() {
|
| buf := &bytes.Buffer{}
|
| - rds.WriteKey(buf, rds.WithoutContext, ancKey)
|
| + ds.WriteKey(buf, ds.WithoutContext, ancKey)
|
| walkPermutations(buf.Bytes(), irg, idxEnts)
|
| }
|
| } else {
|
| @@ -224,7 +224,7 @@ func (sip serializedIndexablePmap) indexEntries(k rds.Key, idxs []*qIndex) *memS
|
| return ret
|
| }
|
|
|
| -func updateIndicies(store *memStore, key rds.Key, oldEnt, newEnt rds.PropertyMap) {
|
| +func updateIndicies(store *memStore, key ds.Key, oldEnt, newEnt ds.PropertyMap) {
|
| idxColl := store.GetCollection("idx")
|
| if idxColl == nil {
|
| idxColl = store.SetCollection("idx", nil)
|
|
|