datastore

Dec 22, 2019

Changes in this version

type ClientOption

+ func WithGRPCDialOption(opt grpc.DialOption) ClientOption

Mar 27, 2018

Changes in this version

type Client

+ AllocateIDs func(ctx context.Context, keys []Key) ([]Key, error)

Jan 24, 2018

Changes in this version

type Key

+ SetNamespace func(namespace string)

Jan 9, 2018

Changes in this version

type Client

+ Context func() context.Context

+ SetContext func(ctx context.Context)

type Middleware

+ AllocateIDs func(info *MiddlewareInfo, keys []Key) ([]Key, error)

+ Count func(info *MiddlewareInfo, q Query, qDump *QueryDump) (int, error)

Dec 13, 2017

Changes in this version

type Client

+ AppendMiddleware func(middleware Middleware)

+ RemoveMiddleware func(middleware Middleware) bool

+ type Middleware interface

+ DeleteMultiWithTx func(info *MiddlewareInfo, keys []Key) error

+ DeleteMultiWithoutTx func(info *MiddlewareInfo, keys []Key) error

+ GetAll func(info *MiddlewareInfo, q Query, qDump *QueryDump, psList *[]PropertyList) ([]Key, error)

+ GetMultiWithTx func(info *MiddlewareInfo, keys []Key, psList []PropertyList) error

+ GetMultiWithoutTx func(info *MiddlewareInfo, keys []Key, psList []PropertyList) error

+ Next func(info *MiddlewareInfo, q Query, qDump *QueryDump, iter Iterator, ...) (Key, error)

+ PostCommit func(info *MiddlewareInfo, tx Transaction, commit Commit) error

+ PostRollback func(info *MiddlewareInfo, tx Transaction) error

+ PutMultiWithTx func(info *MiddlewareInfo, keys []Key, psList []PropertyList) ([]PendingKey, error)

+ PutMultiWithoutTx func(info *MiddlewareInfo, keys []Key, psList []PropertyList) ([]Key, error)

+ Run func(info *MiddlewareInfo, q Query, qDump *QueryDump) Iterator

+ type MiddlewareInfo struct

+ Client Client

+ Context context.Context

+ Next Middleware

+ Transaction Transaction

Dec 6, 2017

Changes in this version

+ type BatchErrHandler func(err error) error

+ type BatchPutHandler func(key Key, err error) error

+ type TxBatchPutHandler func(pKey PendingKey, err error) error

Dec 4, 2017

Changes in this version

+ type CacheInfo struct

+ Client Client

+ Context context.Context

+ Next CacheStrategy

+ Transaction Transaction

+ type CacheStrategy interface

+ DeleteMultiWithTx func(info *CacheInfo, keys []Key) error

+ DeleteMultiWithoutTx func(info *CacheInfo, keys []Key) error

+ GetAll func(info *CacheInfo, q Query, qDump *QueryDump, psList *[]PropertyList) ([]Key, error)

+ GetMultiWithTx func(info *CacheInfo, keys []Key, psList []PropertyList) error

+ GetMultiWithoutTx func(info *CacheInfo, keys []Key, psList []PropertyList) error

+ Next func(info *CacheInfo, q Query, qDump *QueryDump, iter Iterator, ps *PropertyList) (Key, error)

+ PostCommit func(info *CacheInfo, tx Transaction, commit Commit) error

+ PostRollback func(info *CacheInfo, tx Transaction) error

+ PutMultiWithTx func(info *CacheInfo, keys []Key, psList []PropertyList) ([]PendingKey, error)

+ PutMultiWithoutTx func(info *CacheInfo, keys []Key, psList []PropertyList) ([]Key, error)

+ Run func(info *CacheInfo, q Query, qDump *QueryDump) Iterator

type Client

+ AppendCacheStrategy func(strategy CacheStrategy)

+ DecodeKey func(encoded string) (Key, error)

+ RemoveCacheStrategy func(strategy CacheStrategy) bool

type Query

+ Dump func() *QueryDump

+ type QueryDump struct

+ Ancestor Key

+ Distinct bool

+ End Cursor

+ EventualConsistency bool

+ Filter []*QueryFilterCondition

+ KeysOnly bool

+ Kind string

+ Limit int

+ Namespace string

+ Offset int

+ Order []string

+ Project []string

+ Start Cursor

+ Transaction Transaction

+ func (dump *QueryDump) String() string

+ type QueryFilterCondition struct

+ Filter string

+ Value interface{}

Nov 21, 2017

Changes in this version

type Key

+ Equal func(o Key) bool

+ Incomplete func() bool

Nov 20, 2017

Changes in this version

type Client

+ SwapContext func(ctx context.Context) context.Context

Nov 14, 2017

Changes in this version

type Client

+ Delete func(ctx context.Context, key Key) error

+ DeleteMulti func(ctx context.Context, keys []Key) error

+ Get func(ctx context.Context, key Key, dst interface{}) error

+ GetMulti func(ctx context.Context, keys []Key, dst interface{}) error

+ Put func(ctx context.Context, key Key, src interface{}) (Key, error)

+ PutMulti func(ctx context.Context, keys []Key, src interface{}) ([]Key, error)

Nov 9, 2017

Changes in this version

+ var ErrConcurrentTransaction = errors.New("datastore: concurrent transaction")

+ var ErrInvalidEntityType = errors.New("datastore: invalid entity type")

+ var ErrInvalidKey = errors.New("datastore: invalid key")

+ var ErrNoSuchEntity = errors.New("datastore: no such entity")

+ var LoadEntity = loadEntity

+ var SaveEntity = saveEntity

+ var SuppressErrFieldMismatch = true

+ func LoadStruct(ctx context.Context, dst interface{}, p []Property) error

+ type Batch struct

+ Client Client

+ func (b *Batch) Delete(key Key) chan error

+ func (b *Batch) Exec(ctx context.Context) error

+ func (b *Batch) Get(key Key, dst interface{}) chan error

+ func (b *Batch) Put(key Key, src interface{}) chan *PutResult

+ func (b *Batch) UnwrapPutResult(r *PutResult) (Key, error)

+ type Client interface

+ AllocatedIDs func(ctx context.Context, keys []Key) ([]Key, error)

+ Batch func() *Batch

+ Close func() error

+ Count func(ctx context.Context, q Query) (int, error)

+ DecodeCursor func(s string) (Cursor, error)

+ GetAll func(ctx context.Context, q Query, dst interface{}) ([]Key, error)

+ IDKey func(kind string, id int64, parent Key) Key

+ IncompleteKey func(kind string, parent Key) Key

+ NameKey func(kind, name string, parent Key) Key

+ NewQuery func(kind string) Query

+ NewTransaction func(ctx context.Context) (Transaction, error)

+ Run func(ctx context.Context, q Query) Iterator

+ RunInTransaction func(ctx context.Context, f func(tx Transaction) error) (Commit, error)

+ type ClientGenerator func(ctx context.Context, opts ...ClientOption) (Client, error)

+ var FromContext ClientGenerator

+ type ClientOption interface

+ Apply func(*internal.ClientSettings)

+ func WithCredentialsFile(filename string) ClientOption

+ func WithHTTPClient(client *http.Client) ClientOption

+ func WithProjectID(projectID string) ClientOption

+ func WithScopes(scope ...string) ClientOption

+ func WithTokenSource(s oauth2.TokenSource) ClientOption

+ type Commit interface

+ Key func(p PendingKey) Key

+ type Cursor interface

+ String func() string

+ type Entity struct

+ Key Key

+ Properties []Property

+ type ErrFieldMismatch struct

+ FieldName string

+ Reason string

+ StructType reflect.Type

+ func (e *ErrFieldMismatch) Error() string

+ type GeoPoint struct

+ Lat float64

+ Lng float64

+ type Iterator interface

+ Cursor func() (Cursor, error)

+ Next func(dst interface{}) (Key, error)

+ type Key interface

+ Encode func() string

+ GobDecode func(buf []byte) error

+ GobEncode func() ([]byte, error)

+ ID func() int64

+ Kind func() string

+ MarshalJSON func() ([]byte, error)

+ Name func() string

+ Namespace func() string

+ ParentKey func() Key

+ String func() string

+ UnmarshalJSON func(buf []byte) error

+ type KeyLoader interface

+ LoadKey func(ctx context.Context, k Key) error

+ type MultiError []error

+ func (m MultiError) Error() string

+ type PendingKey interface

+ StoredContext func() context.Context

+ type Property struct

+ Name string

+ NoIndex bool

+ Value interface{}

+ func SaveStruct(ctx context.Context, src interface{}) ([]Property, error)

+ type PropertyList []Property

+ func (l *PropertyList) Load(ctx context.Context, p []Property) error

+ func (l *PropertyList) Save(ctx context.Context) ([]Property, error)

+ type PropertyLoadSaver interface

+ Load func(ctx context.Context, ps []Property) error

+ Save func(ctx context.Context) ([]Property, error)

+ type PropertyTranslator interface

+ FromPropertyValue func(ctx context.Context, p Property) (dst interface{}, err error)

+ ToPropertyValue func(ctx context.Context) (interface{}, error)

+ type PutResult struct

+ Err error

+ Key Key

+ type Query interface

+ Ancestor func(ancestor Key) Query

+ Distinct func() Query

+ End func(c Cursor) Query

+ EventualConsistency func() Query

+ Filter func(filterStr string, value interface{}) Query

+ KeysOnly func() Query

+ Limit func(limit int) Query

+ Namespace func(ns string) Query

+ Offset func(offset int) Query

+ Order func(fieldName string) Query

+ Project func(fieldNames ...string) Query

+ Start func(c Cursor) Query

+ Transaction func(t Transaction) Query

+ type Transaction interface

+ Batch func() *TransactionBatch

+ Commit func() (Commit, error)

+ Delete func(key Key) error

+ DeleteMulti func(keys []Key) error

+ Get func(key Key, dts interface{}) error

+ GetMulti func(keys []Key, dst interface{}) error

+ Put func(key Key, src interface{}) (PendingKey, error)

+ PutMulti func(keys []Key, src interface{}) ([]PendingKey, error)

+ Rollback func() error

+ type TransactionBatch struct

+ Transaction Transaction

+ func (b *TransactionBatch) Delete(key Key) chan error

+ func (b *TransactionBatch) Exec()

+ func (b *TransactionBatch) Get(key Key, dst interface{}) chan error

+ func (b *TransactionBatch) Put(key Key, src interface{}) chan *TransactionPutResult

+ func (b *TransactionBatch) UnwrapPutResult(r *TransactionPutResult) (PendingKey, error)

+ type TransactionPutResult struct

+ Err error

+ PendingKey PendingKey