| Index: go/src/infra/gae/libs/wrapper/gae/datastore.go
|
| diff --git a/go/src/infra/gae/libs/wrapper/gae/datastore.go b/go/src/infra/gae/libs/wrapper/gae/datastore.go
|
| deleted file mode 100644
|
| index cb99390ae955a130a0423a4fb174f4d1c8ed1b59..0000000000000000000000000000000000000000
|
| --- a/go/src/infra/gae/libs/wrapper/gae/datastore.go
|
| +++ /dev/null
|
| @@ -1,118 +0,0 @@
|
| -// 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 gae
|
| -
|
| -import (
|
| - "golang.org/x/net/context"
|
| -
|
| - "appengine/datastore"
|
| -
|
| - "github.com/mjibson/goon"
|
| -
|
| - "infra/gae/libs/wrapper"
|
| -)
|
| -
|
| -// useDS adds a wrapper.Datastore implementation to context, accessible
|
| -// by wrapper.GetDS(c)
|
| -func useDS(c context.Context) context.Context {
|
| - return wrapper.SetDSFactory(c, func(ci context.Context) wrapper.Datastore {
|
| - return &dsImpl{ctx(ci), ci}
|
| - })
|
| -}
|
| -
|
| -////////// Query
|
| -
|
| -type queryImpl struct{ *datastore.Query }
|
| -
|
| -func (q queryImpl) Distinct() wrapper.DSQuery {
|
| - return queryImpl{q.Query.Distinct()}
|
| -}
|
| -func (q queryImpl) End(c wrapper.DSCursor) wrapper.DSQuery {
|
| - return queryImpl{q.Query.End(c.(datastore.Cursor))}
|
| -}
|
| -func (q queryImpl) EventualConsistency() wrapper.DSQuery {
|
| - return queryImpl{q.Query.EventualConsistency()}
|
| -}
|
| -func (q queryImpl) KeysOnly() wrapper.DSQuery {
|
| - return queryImpl{q.Query.KeysOnly()}
|
| -}
|
| -func (q queryImpl) Limit(limit int) wrapper.DSQuery {
|
| - return queryImpl{q.Query.Limit(limit)}
|
| -}
|
| -func (q queryImpl) Offset(offset int) wrapper.DSQuery {
|
| - return queryImpl{q.Query.Offset(offset)}
|
| -}
|
| -func (q queryImpl) Order(fieldName string) wrapper.DSQuery {
|
| - return queryImpl{q.Query.Order(fieldName)}
|
| -}
|
| -func (q queryImpl) Start(c wrapper.DSCursor) wrapper.DSQuery {
|
| - return queryImpl{q.Query.Start(c.(datastore.Cursor))}
|
| -}
|
| -func (q queryImpl) Ancestor(ancestor *datastore.Key) wrapper.DSQuery {
|
| - return queryImpl{q.Query.Ancestor(ancestor)}
|
| -}
|
| -func (q queryImpl) Project(fieldNames ...string) wrapper.DSQuery {
|
| - return queryImpl{q.Query.Project(fieldNames...)}
|
| -}
|
| -func (q queryImpl) Filter(filterStr string, value interface{}) wrapper.DSQuery {
|
| - return queryImpl{q.Query.Filter(filterStr, value)}
|
| -}
|
| -
|
| -////////// Iterator
|
| -
|
| -type iteratorImpl struct {
|
| - *goon.Iterator
|
| -}
|
| -
|
| -func (i iteratorImpl) Cursor() (wrapper.DSCursor, error) {
|
| - return i.Iterator.Cursor()
|
| -}
|
| -
|
| -////////// Datastore
|
| -
|
| -type dsImpl struct {
|
| - *goon.Goon
|
| - c context.Context
|
| -}
|
| -
|
| -// Kinder
|
| -func (g *dsImpl) KindNameResolver() goon.KindNameResolver {
|
| - return g.Goon.KindNameResolver
|
| -}
|
| -func (g *dsImpl) SetKindNameResolver(knr goon.KindNameResolver) {
|
| - g.Goon.KindNameResolver = knr
|
| -}
|
| -
|
| -// NewKeyer
|
| -func (g *dsImpl) NewKey(kind, stringID string, intID int64, parent *datastore.Key) *datastore.Key {
|
| - return datastore.NewKey(g.Goon.Context, kind, stringID, intID, parent)
|
| -}
|
| -func (g *dsImpl) NewKeyObj(obj interface{}) *datastore.Key {
|
| - return g.Key(obj)
|
| -}
|
| -func (g *dsImpl) NewKeyObjError(obj interface{}) (*datastore.Key, error) {
|
| - return g.KeyError(obj)
|
| -}
|
| -
|
| -// DSQueryer
|
| -func (g *dsImpl) NewQuery(kind string) wrapper.DSQuery {
|
| - return queryImpl{datastore.NewQuery(kind)}
|
| -}
|
| -func (g *dsImpl) Run(q wrapper.DSQuery) wrapper.DSIterator {
|
| - return iteratorImpl{g.Goon.Run(q.(queryImpl).Query)}
|
| -}
|
| -func (g *dsImpl) Count(q wrapper.DSQuery) (int, error) {
|
| - return g.Goon.Count(q.(queryImpl).Query)
|
| -}
|
| -func (g *dsImpl) GetAll(q wrapper.DSQuery, dst interface{}) ([]*datastore.Key, error) {
|
| - return g.Goon.GetAll(q.(queryImpl).Query, dst)
|
| -}
|
| -
|
| -// Transactioner
|
| -func (g *dsImpl) RunInTransaction(f func(c context.Context) error, opts *datastore.TransactionOptions) error {
|
| - return g.Goon.RunInTransaction(func(ig *goon.Goon) error {
|
| - return f(context.WithValue(g.c, goonContextKey, ig))
|
| - }, opts)
|
| -}
|
|
|