Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

datastore

package module

Go to main page

Versions in this module

v2

v2.2.0

Jul 15, 2022

Changes in this version

type Query

+ FilterField func(fieldName, operator string, value interface{}) Query

type QueryFilterCondition

+ FieldName string

+ Operator string

v2.1.0

Jul 15, 2022

v2.0.0

Jul 14, 2022

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, h BatchErrHandler)

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

+ func (b *Batch) Get(key Key, dst interface{}, h BatchErrHandler)

+ func (b *Batch) Put(key Key, src interface{}, h BatchPutHandler)

+ type BatchErrHandler func(err error) error

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

+ type Client interface

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

+ AppendMiddleware func(middleware Middleware)

+ Batch func() *Batch

+ Close func() error

+ Context func() context.Context

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

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

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

+ 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

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

+ GetMulti func(ctx context.Context, keys []Key, dst interface{}) 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)

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

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

+ RemoveMiddleware func(middleware Middleware) bool

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

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

+ SetContext func(ctx context.Context)

+ 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 WithGRPCDialOption(opt grpc.DialOption) 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

+ Equal func(o Key) bool

+ GobDecode func(buf []byte) error

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

+ ID func() int64

+ Incomplete func() bool

+ Kind func() string

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

+ Name func() string

+ Namespace func() string

+ ParentKey func() Key

+ SetNamespace func(namespace string)

+ String func() string

+ UnmarshalJSON func(buf []byte) error

+ type KeyLoader interface

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

+ type Middleware interface

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

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

+ 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

+ 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 Query interface

+ Ancestor func(ancestor Key) Query

+ Distinct func() Query

+ DistinctOn func(fieldNames ...string) Query

+ Dump func() *QueryDump

+ 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 QueryDump struct

+ Ancestor Key

+ Distinct bool

+ DistinctOn []string

+ 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{}

+ type Transaction interface

+ Batch func() *TransactionBatch

+ Commit func() (Commit, error)

+ Delete func(key Key) error

+ DeleteMulti func(keys []Key) error

+ Get func(key Key, dst 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, h BatchErrHandler)

+ func (b *TransactionBatch) Exec() error

+ func (b *TransactionBatch) Get(key Key, dst interface{}, h BatchErrHandler)

+ func (b *TransactionBatch) Put(key Key, src interface{}, h TxBatchPutHandler)

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

Other modules containing this package

go.mercari.io/datastore