Index: service/datastore/key.go |
diff --git a/service/datastore/key.go b/service/datastore/key.go |
index 4b11735f6a8e7be2a2b6e4da1b00dac23b9c4e35..8359203eb7a879bd476a4fc6d7cbaccd1b010ddb 100644 |
--- a/service/datastore/key.go |
+++ b/service/datastore/key.go |
@@ -53,48 +53,48 @@ func (k KeyTok) Less(other KeyTok) bool { |
return a.Less(&b) |
} |
-// Key is the type used for all datastore operations. |
-type Key struct { |
- appID string |
- namespace string |
- toks []KeyTok |
+// KeyContext is the context in which a key is generated. |
+type KeyContext struct { |
+ AppID string |
+ Namespace string |
} |
-var _ interface { |
- json.Marshaler |
- json.Unmarshaler |
-} = (*Key)(nil) |
+// Matches returns true iff the AppID and Namespace parameters are the same for |
+// the two KeyContext instances. |
+func (kc KeyContext) Matches(o KeyContext) bool { |
+ return (kc.AppID == o.AppID && kc.Namespace == o.Namespace) |
+} |
-// NewKeyToks creates a new Key. It is the Key implementation returned from the |
-// various PropertyMap serialization routines, as well as the native key |
+// NewKeyToks creates a new Key. It is the Key implementation returned from |
+// the various PropertyMap serialization routines, as well as the native key |
// implementation for the in-memory implementation of gae. |
// |
-// See Interface.NewKeyToks for a version of this function which automatically |
+// See NewKeyToks for a version of this function which automatically |
// provides aid and ns. |
-func NewKeyToks(aid, ns string, toks []KeyTok) *Key { |
+func (kc KeyContext) NewKeyToks(toks []KeyTok) *Key { |
if len(toks) == 0 { |
return nil |
} |
newToks := make([]KeyTok, len(toks)) |
copy(newToks, toks) |
- return &Key{aid, ns, newToks} |
+ return &Key{kc, newToks} |
} |
-// NewKey is a wrapper around NewToks which has an interface similar |
-// to NewKey in the SDK. |
+// NewKey is a wrapper around NewToks which has an interface similar to NewKey |
+// in the SDK. |
// |
-// See Interface.NewKey for a version of this function which automatically |
-// provides aid and ns. |
-func NewKey(aid, ns, kind, stringID string, intID int64, parent *Key) *Key { |
+// See NewKey for a version of this function which automatically provides aid |
+// and ns. |
+func (kc KeyContext) NewKey(kind, stringID string, intID int64, parent *Key) *Key { |
if parent == nil { |
- return &Key{aid, ns, []KeyTok{{kind, intID, stringID}}} |
+ return &Key{kc, []KeyTok{{kind, intID, stringID}}} |
} |
toks := parent.toks |
newToks := make([]KeyTok, len(toks), len(toks)+1) |
copy(newToks, toks) |
newToks = append(newToks, KeyTok{kind, intID, stringID}) |
- return &Key{aid, ns, newToks} |
+ return &Key{kc, newToks} |
} |
// MakeKey is a convenience function for manufacturing a *Key. It should only |
@@ -102,7 +102,7 @@ func NewKey(aid, ns, kind, stringID string, intID int64, parent *Key) *Key { |
// |
// elems is pairs of (string, string|int|int32|int64) pairs, which correspond to |
// Kind/id pairs. Example: |
-// MakeKey("aid", "namespace", "Parent", 1, "Child", "id") |
+// KeyContext{"aid", "namespace"}.MakeKey("Parent", 1, "Child", "id") |
// |
// Would create the key: |
// aid:namespace:/Parent,1/Child,id |
@@ -110,9 +110,9 @@ func NewKey(aid, ns, kind, stringID string, intID int64, parent *Key) *Key { |
// If elems is not parsable (e.g. wrong length, wrong types, etc.) this method |
// will panic. |
// |
-// See Interface.MakeKey for a version of this function which automatically |
+// See MakeKey for a version of this function which automatically |
// provides aid and ns. |
-func MakeKey(aid, ns string, elems ...interface{}) *Key { |
+func (kc KeyContext) MakeKey(elems ...interface{}) *Key { |
if len(elems) == 0 { |
return nil |
} |
@@ -147,9 +147,20 @@ func MakeKey(aid, ns string, elems ...interface{}) *Key { |
} |
} |
- return NewKeyToks(aid, ns, toks) |
+ return kc.NewKeyToks(toks) |
+} |
+ |
+// Key is the type used for all datastore operations. |
+type Key struct { |
+ kc KeyContext |
+ toks []KeyTok |
} |
+var _ interface { |
+ json.Marshaler |
+ json.Unmarshaler |
+} = (*Key)(nil) |
+ |
// NewKeyEncoded decodes and returns a *Key |
func NewKeyEncoded(encoded string) (ret *Key, err error) { |
ret = &Key{} |
@@ -167,8 +178,10 @@ func NewKeyEncoded(encoded string) (ret *Key, err error) { |
return |
} |
- ret.appID = r.GetApp() |
- ret.namespace = r.GetNameSpace() |
+ ret.kc = KeyContext{ |
+ AppID: r.GetApp(), |
+ Namespace: r.GetNameSpace(), |
+ } |
ret.toks = make([]KeyTok, len(r.Path.Element)) |
for i, e := range r.Path.Element { |
ret.toks[i] = KeyTok{ |
@@ -187,10 +200,16 @@ func (k *Key) LastTok() KeyTok { |
} |
// AppID returns the application ID that this Key is for. |
-func (k *Key) AppID() string { return k.appID } |
+func (k *Key) AppID() string { return k.kc.AppID } |
// Namespace returns the namespace that this Key is for. |
-func (k *Key) Namespace() string { return k.namespace } |
+func (k *Key) Namespace() string { return k.kc.Namespace } |
+ |
+// KeyContext returns the KeyContext that this Key is using. |
+func (k *Key) KeyContext() *KeyContext { |
+ kc := k.kc |
+ return &kc |
+} |
// Kind returns the Kind of the child KeyTok |
func (k *Key) Kind() string { return k.toks[len(k.toks)-1].Kind } |
@@ -205,7 +224,7 @@ func (k *Key) IntID() int64 { return k.toks[len(k.toks)-1].IntID } |
// AID:NS:/Kind,id/Kind,id/... |
func (k *Key) String() string { |
b := bytes.NewBuffer(make([]byte, 0, 512)) |
- fmt.Fprintf(b, "%s:%s:", k.appID, k.namespace) |
+ fmt.Fprintf(b, "%s:%s:", k.kc.AppID, k.kc.Namespace) |
for _, t := range k.toks { |
if t.StringID != "" { |
fmt.Fprintf(b, "/%s,%q", t.Kind, t.StringID) |
@@ -221,15 +240,15 @@ func (k *Key) IsIncomplete() bool { |
return k.LastTok().IsIncomplete() |
} |
-// Valid determines if a key is valid, according to a couple rules: |
+// Valid determines if a key is valid, according to a couple of rules: |
// - k is not nil |
// - every token of k: |
// - (if !allowSpecial) token's kind doesn't start with '__' |
// - token's kind and appid are non-blank |
// - token is not incomplete |
// - all tokens have the same namespace and appid |
-func (k *Key) Valid(allowSpecial bool, aid, ns string) bool { |
- if aid != k.appID || ns != k.namespace { |
+func (k *Key) Valid(allowSpecial bool, kc KeyContext) bool { |
+ if !kc.Matches(k.kc) { |
return false |
} |
for _, t := range k.toks { |
@@ -252,11 +271,14 @@ func (k *Key) Valid(allowSpecial bool, aid, ns string) bool { |
// PartialValid returns true iff this key is suitable for use in a Put |
// operation. This is the same as Valid(k, false, ...), but also allowing k to |
// be IsIncomplete(). |
-func (k *Key) PartialValid(aid, ns string) bool { |
+func (k *Key) PartialValid(kc KeyContext) bool { |
if k.IsIncomplete() { |
- k = NewKey(k.AppID(), k.Namespace(), k.Kind(), "", 1, k.Parent()) |
+ if !kc.Matches(k.kc) { |
+ return false |
+ } |
+ k = kc.NewKey(k.Kind(), "", 1, k.Parent()) |
} |
- return k.Valid(false, aid, ns) |
+ return k.Valid(false, kc) |
} |
// Parent returns the parent Key of this *Key, or nil. The parent |
@@ -265,7 +287,7 @@ func (k *Key) Parent() *Key { |
if len(k.toks) <= 1 { |
return nil |
} |
- return &Key{k.appID, k.namespace, k.toks[:len(k.toks)-1]} |
+ return k.kc.NewKeyToks(k.toks[:len(k.toks)-1]) |
} |
// MarshalJSON allows this key to be automatically marshaled by encoding/json. |
@@ -293,11 +315,11 @@ func (k *Key) Encode() string { |
} |
} |
var namespace *string |
- if k.namespace != "" { |
- namespace = &k.namespace |
+ if ns := k.kc.Namespace; ns != "" { |
+ namespace = &ns |
} |
r, err := proto.Marshal(&pb.Reference{ |
- App: &k.appID, |
+ App: &k.kc.AppID, |
NameSpace: namespace, |
Path: &pb.Path{ |
Element: e, |
@@ -351,15 +373,15 @@ func (k *Key) Root() *Key { |
// Less returns true iff k would sort before other. |
func (k *Key) Less(other *Key) bool { |
- if k.appID < other.appID { |
+ if k.kc.AppID < other.kc.AppID { |
return true |
- } else if k.appID > other.appID { |
+ } else if k.kc.AppID > other.kc.AppID { |
return false |
} |
- if k.namespace < other.namespace { |
+ if k.kc.Namespace < other.kc.Namespace { |
return true |
- } else if k.namespace > other.namespace { |
+ } else if k.kc.Namespace > other.kc.Namespace { |
return false |
} |
@@ -380,7 +402,7 @@ func (k *Key) Less(other *Key) bool { |
// HasAncestor returns true iff other is an ancestor of k (or if other == k). |
func (k *Key) HasAncestor(other *Key) bool { |
- if k.appID != other.appID || k.namespace != other.namespace { |
+ if !k.kc.Matches(other.kc) { |
return false |
} |
if len(k.toks) < len(other.toks) { |
@@ -400,9 +422,9 @@ func (k *Key) HasAncestor(other *Key) bool { |
// https://cloud.google.com/datastore/docs/apis/gql/gql_reference |
func (k *Key) GQL() string { |
ret := &bytes.Buffer{} |
- fmt.Fprintf(ret, "KEY(DATASET(%s)", gqlQuoteString(k.appID)) |
- if k.namespace != "" { |
- fmt.Fprintf(ret, ", NAMESPACE(%s)", gqlQuoteString(k.namespace)) |
+ fmt.Fprintf(ret, "KEY(DATASET(%s)", gqlQuoteString(k.kc.AppID)) |
+ if ns := k.kc.Namespace; ns != "" { |
+ fmt.Fprintf(ret, ", NAMESPACE(%s)", gqlQuoteString(ns)) |
} |
for _, t := range k.toks { |
if t.IntID != 0 { |
@@ -428,8 +450,7 @@ func (k *Key) Equal(other *Key) bool { |
// This asserts equality for the full lineage of the key, except for its last |
// token ID. |
func (k *Key) IncompleteEqual(other *Key) (ret bool) { |
- ret = (k.appID == other.appID && |
- k.namespace == other.namespace && |
+ ret = (k.kc.Matches(other.kc) && |
len(k.toks) == len(other.toks)) |
if ret { |
for i, t := range k.toks { |
@@ -454,7 +475,7 @@ func (k *Key) Incomplete() *Key { |
if k.IsIncomplete() { |
return k |
} |
- return NewKey(k.appID, k.namespace, k.Kind(), "", 0, k.Parent()) |
+ return k.kc.NewKey(k.Kind(), "", 0, k.Parent()) |
} |
// WithID returns the key generated by setting the ID of its last token to |
@@ -467,7 +488,7 @@ func (k *Key) WithID(stringID string, intID int64) *Key { |
if k.StringID() == stringID && k.IntID() == intID { |
return k |
} |
- return NewKey(k.appID, k.namespace, k.Kind(), stringID, intID, k.Parent()) |
+ return k.kc.NewKey(k.Kind(), stringID, intID, k.Parent()) |
} |
// Split componentizes the key into pieces (AppID, Namespace and tokens) |
@@ -477,8 +498,8 @@ func (k *Key) WithID(stringID string, intID int64) *Key { |
// toks is guaranteed to be empty if and only if k is nil. If k is non-nil then |
// it contains at least one token. |
func (k *Key) Split() (appID, namespace string, toks []KeyTok) { |
- appID = k.appID |
- namespace = k.namespace |
+ appID = k.kc.AppID |
+ namespace = k.kc.Namespace |
toks = make([]KeyTok, len(k.toks)) |
copy(toks, k.toks) |
return |
@@ -489,8 +510,8 @@ func (k *Key) Split() (appID, namespace string, toks []KeyTok) { |
// It uses https://cloud.google.com/appengine/articles/storage_breakdown?csw=1 |
// as a guide for these values. |
func (k *Key) EstimateSize() int64 { |
- ret := int64(len(k.appID)) |
- ret += int64(len(k.namespace)) |
+ ret := int64(len(k.kc.AppID)) |
+ ret += int64(len(k.kc.Namespace)) |
for _, t := range k.toks { |
ret += int64(len(t.Kind)) |
if t.StringID != "" { |