| Index: impl/dummy/dummy.go
|
| diff --git a/impl/dummy/dummy.go b/impl/dummy/dummy.go
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..c9a607926b385391689e11d650de5e7e4da2fba2
|
| --- /dev/null
|
| +++ b/impl/dummy/dummy.go
|
| @@ -0,0 +1,173 @@
|
| +// 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 dummy
|
| +
|
| +import (
|
| + "fmt"
|
| + "runtime"
|
| + "strings"
|
| + "time"
|
| +
|
| + "github.com/luci/gae/service/info"
|
| + "github.com/luci/gae/service/memcache"
|
| + "github.com/luci/gae/service/rawdatastore"
|
| + "github.com/luci/gae/service/taskqueue"
|
| + "golang.org/x/net/context"
|
| +)
|
| +
|
| +const niFmtStr = "dummy: method %s.%s is not implemented"
|
| +
|
| +// ni returns an error whose message is an appropriate expansion of niFmtStr.
|
| +//
|
| +// It walks the stack to find out what interface and method it's being
|
| +// called from. For example, it might return a message which looks like:
|
| +// dummy: method RawDatastore.Get is not implemented
|
| +//
|
| +// This allows the various dummy objects below to have clear boilerplate which
|
| +// avoids copy+paste errors (such as if each one of them filled in the template
|
| +// manually).
|
| +//
|
| +// If this function is somehow called from something other than one of the dummy
|
| +// objects in this package, it will substitute the string UNKNOWN for the
|
| +// interface and/or the method in the niFmtStr template.
|
| +func ni() error {
|
| + iface := "UNKNOWN"
|
| + funcName := "UNKNOWN"
|
| +
|
| + if ptr, _, _, ok := runtime.Caller(1); ok {
|
| + f := runtime.FuncForPC(ptr)
|
| + n := f.Name()
|
| + if n != "" {
|
| + parts := strings.Split(n, ".")
|
| + if len(parts) > 2 {
|
| + switch parts[len(parts)-2] {
|
| + case "rds":
|
| + iface = "RawDatastore"
|
| + case "mc":
|
| + iface = "Memcache"
|
| + case "tq":
|
| + iface = "TaskQueue"
|
| + case "i":
|
| + iface = "Info"
|
| + }
|
| + funcName = parts[len(parts)-1]
|
| + }
|
| + }
|
| + }
|
| +
|
| + return fmt.Errorf(niFmtStr, iface, funcName)
|
| +}
|
| +
|
| +/////////////////////////////////// rds ////////////////////////////////////
|
| +
|
| +type rds struct{}
|
| +
|
| +func (rds) NewKey(string, string, int64, rawdatastore.Key) rawdatastore.Key { panic(ni()) }
|
| +func (rds) DecodeKey(string) (rawdatastore.Key, error) { panic(ni()) }
|
| +func (rds) KeyFromTokens(a, n string, t []rawdatastore.KeyTok) (rawdatastore.Key, error) { panic(ni()) }
|
| +func (rds) Put(rawdatastore.Key, rawdatastore.PropertyLoadSaver) (rawdatastore.Key, error) {
|
| + panic(ni())
|
| +}
|
| +func (rds) Get(rawdatastore.Key, rawdatastore.PropertyLoadSaver) error { panic(ni()) }
|
| +func (rds) Delete(rawdatastore.Key) error { panic(ni()) }
|
| +func (rds) PutMulti([]rawdatastore.Key, []rawdatastore.PropertyLoadSaver) ([]rawdatastore.Key, error) {
|
| + panic(ni())
|
| +}
|
| +func (rds) GetMulti([]rawdatastore.Key, []rawdatastore.PropertyLoadSaver) error { panic(ni()) }
|
| +func (rds) DeleteMulti([]rawdatastore.Key) error { panic(ni()) }
|
| +func (rds) NewQuery(string) rawdatastore.Query { panic(ni()) }
|
| +func (rds) Run(rawdatastore.Query) rawdatastore.Iterator { panic(ni()) }
|
| +func (rds) GetAll(rawdatastore.Query, *[]rawdatastore.PropertyMap) ([]rawdatastore.Key, error) {
|
| + panic(ni())
|
| +}
|
| +func (rds) Count(rawdatastore.Query) (int, error) { panic(ni()) }
|
| +func (rds) RunInTransaction(func(context.Context) error, *rawdatastore.TransactionOptions) error {
|
| + panic(ni())
|
| +}
|
| +
|
| +var dummyRDSInst = rds{}
|
| +
|
| +// RawDatastore returns a dummy rawdatastore.Interface implementation suitable
|
| +// for embedding. Every method panics with a message containing the name of the
|
| +// method which was unimplemented.
|
| +func RawDatastore() rawdatastore.Interface { return dummyRDSInst }
|
| +
|
| +/////////////////////////////////// mc ////////////////////////////////////
|
| +
|
| +type mc struct{}
|
| +
|
| +func (mc) Add(memcache.Item) error { panic(ni()) }
|
| +func (mc) NewItem(key string) memcache.Item { panic(ni()) }
|
| +func (mc) Set(memcache.Item) error { panic(ni()) }
|
| +func (mc) Get(string) (memcache.Item, error) { panic(ni()) }
|
| +func (mc) Delete(string) error { panic(ni()) }
|
| +func (mc) CompareAndSwap(memcache.Item) error { panic(ni()) }
|
| +func (mc) AddMulti([]memcache.Item) error { panic(ni()) }
|
| +func (mc) SetMulti([]memcache.Item) error { panic(ni()) }
|
| +func (mc) GetMulti([]string) (map[string]memcache.Item, error) { panic(ni()) }
|
| +func (mc) DeleteMulti([]string) error { panic(ni()) }
|
| +func (mc) CompareAndSwapMulti([]memcache.Item) error { panic(ni()) }
|
| +func (mc) Increment(string, int64, uint64) (uint64, error) { panic(ni()) }
|
| +func (mc) IncrementExisting(string, int64) (uint64, error) { panic(ni()) }
|
| +func (mc) Flush() error { panic(ni()) }
|
| +func (mc) Stats() (*memcache.Statistics, error) { panic(ni()) }
|
| +
|
| +var dummyMCInst = mc{}
|
| +
|
| +// Memcache returns a dummy memcache.Interface implementation suitable for
|
| +// embedding. Every method panics with a message containing the name of the
|
| +// method which was unimplemented.
|
| +func Memcache() memcache.Interface { return dummyMCInst }
|
| +
|
| +/////////////////////////////////// tq ////////////////////////////////////
|
| +
|
| +type tq struct{}
|
| +
|
| +func (tq) Add(*taskqueue.Task, string) (*taskqueue.Task, error) { panic(ni()) }
|
| +func (tq) Delete(*taskqueue.Task, string) error { panic(ni()) }
|
| +func (tq) AddMulti([]*taskqueue.Task, string) ([]*taskqueue.Task, error) { panic(ni()) }
|
| +func (tq) DeleteMulti([]*taskqueue.Task, string) error { panic(ni()) }
|
| +func (tq) Lease(int, string, int) ([]*taskqueue.Task, error) { panic(ni()) }
|
| +func (tq) LeaseByTag(int, string, int, string) ([]*taskqueue.Task, error) { panic(ni()) }
|
| +func (tq) ModifyLease(*taskqueue.Task, string, int) error { panic(ni()) }
|
| +func (tq) Purge(string) error { panic(ni()) }
|
| +func (tq) QueueStats([]string) ([]taskqueue.Statistics, error) { panic(ni()) }
|
| +
|
| +var dummyTQInst = tq{}
|
| +
|
| +// TaskQueue returns a dummy taskqueue.Interface implementation suitable for
|
| +// embedding. Every method panics with a message containing the name of the
|
| +// method which was unimplemented.
|
| +func TaskQueue() taskqueue.Interface { return dummyTQInst }
|
| +
|
| +/////////////////////////////////// i ////////////////////////////////////
|
| +
|
| +type i struct{}
|
| +
|
| +func (i) AccessToken(scopes ...string) (token string, expiry time.Time, err error) { panic(ni()) }
|
| +func (i) AppID() string { panic(ni()) }
|
| +func (i) ModuleHostname(module, version, instance string) (string, error) { panic(ni()) }
|
| +func (i) ModuleName() string { panic(ni()) }
|
| +func (i) DefaultVersionHostname() string { panic(ni()) }
|
| +func (i) PublicCertificates() ([]info.Certificate, error) { panic(ni()) }
|
| +func (i) RequestID() string { panic(ni()) }
|
| +func (i) ServiceAccount() (string, error) { panic(ni()) }
|
| +func (i) SignBytes(bytes []byte) (keyName string, signature []byte, err error) { panic(ni()) }
|
| +func (i) VersionID() string { panic(ni()) }
|
| +func (i) Namespace(namespace string) (context.Context, error) { panic(ni()) }
|
| +func (i) Datacenter() string { panic(ni()) }
|
| +func (i) InstanceID() string { panic(ni()) }
|
| +func (i) IsDevAppServer() bool { panic(ni()) }
|
| +func (i) ServerSoftware() string { panic(ni()) }
|
| +func (i) IsCapabilityDisabled(err error) bool { panic(ni()) }
|
| +func (i) IsOverQuota(err error) bool { panic(ni()) }
|
| +func (i) IsTimeoutError(err error) bool { panic(ni()) }
|
| +
|
| +var dummyInfoInst = i{}
|
| +
|
| +// Info returns a dummy info.Interface implementation suitable for embedding.
|
| +// Every method panics with a message containing the name of the method which
|
| +// was unimplemented.
|
| +func Info() info.Interface { return dummyInfoInst }
|
|
|
Chromium Code Reviews
