datastore

May 8, 2024

Changes in this version

+ type AggregationWithOptionsResult struct

+ ExplainMetrics *ExplainMetrics

+ Result AggregationResult

type Client

+ func (c *Client) GetAllWithOptions(ctx context.Context, q *Query, dst interface{}, opts ...RunOption) (res GetAllWithOptionsResult, err error)

+ func (c *Client) RunAggregationQueryWithOptions(ctx context.Context, aq *AggregationQuery, opts ...RunOption) (ar AggregationWithOptionsResult, err error)

+ func (c *Client) RunWithOptions(ctx context.Context, q *Query, opts ...RunOption) (it *Iterator)

+ type ExecutionStats struct

+ DebugStats *map[string]interface{}

+ ExecutionDuration *time.Duration

+ ReadOperations int64

+ ResultsReturned int64

+ type ExplainMetrics struct

+ ExecutionStats *ExecutionStats

+ PlanSummary *PlanSummary

+ type ExplainOptions struct

+ Analyze bool

+ type GetAllWithOptionsResult struct

+ ExplainMetrics *ExplainMetrics

+ Keys []*Key

type Iterator

+ ExplainMetrics *ExplainMetrics

+ type PlanSummary struct

+ IndexesUsed []*map[string]interface{}

+ type RunOption interface

Apr 29, 2024

Changes in this version

type Client

+ func (c *Client) ReserveIDs(ctx context.Context, keys []*Key) error

type TransactionOption

+ var BeginLater TransactionOption

Aug 22, 2023

Changes in this version

type AggregationQuery

+ func (aq *AggregationQuery) WithAvg(fieldName string, alias string) *AggregationQuery

+ func (aq *AggregationQuery) WithSum(fieldName string, alias string) *AggregationQuery

Jul 27, 2023

Changes in this version

+ const DefaultDatabaseID

type Client

+ func NewClientWithDatabase(ctx context.Context, projectID, databaseID string, opts ...option.ClientOption) (*Client, error)

Apr 4, 2023

Changes in this version

+ var ErrDifferentKeyAndDstLength = errors.New("datastore: keys and dst slices have different length")

+ type AndFilter struct

+ Filters []EntityFilter

+ type CompositeFilter interface

+ type EntityFilter interface

+ type OrFilter struct

+ Filters []EntityFilter

+ type PropertyFilter struct

+ FieldName string

+ Operator string

+ Value interface{}

type Query

+ func (q *Query) FilterEntity(ef EntityFilter) *Query

Oct 27, 2022

Changes in this version

+ type AggregationQuery struct

+ func (aq *AggregationQuery) WithCount(alias string) *AggregationQuery

+ type AggregationResult map[string]interface

type Client

+ func (c *Client) RunAggregationQuery(ctx context.Context, aq *AggregationQuery) (AggregationResult, error)

+ func (c *Client) WithReadOptions(ro ...ReadOption) *Client

type Query

+ func (q *Query) NewAggregationQuery() *AggregationQuery

+ type ReadOption interface

+ func ReadTime(t time.Time) ReadOption

type TransactionOption

+ func WithReadTime(t time.Time) TransactionOption

Jun 21, 2022

Changes in this version

type Query

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

Aug 12, 2019

Changes in this version

+ const DetectProjectID

+ const ScopeDatastore

+ 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")

+ func LoadStruct(dst interface{}, p []Property) error

+ type Client struct

+ func NewClient(ctx context.Context, projectID string, opts ...option.ClientOption) (*Client, error)

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

+ func (c *Client) Close() error

+ func (c *Client) Count(ctx context.Context, q *Query) (n int, err error)

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

+ func (c *Client) DeleteMulti(ctx context.Context, keys []*Key) (err error)

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

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

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

+ func (c *Client) Mutate(ctx context.Context, muts ...*Mutation) (ret []*Key, err error)

+ func (c *Client) NewTransaction(ctx context.Context, opts ...TransactionOption) (t *Transaction, err error)

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

+ func (c *Client) PutMulti(ctx context.Context, keys []*Key, src interface{}) (ret []*Key, err error)

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

+ func (c *Client) RunInTransaction(ctx context.Context, f func(tx *Transaction) error, opts ...TransactionOption) (cmt *Commit, err error)

+ type Commit struct

+ func (c *Commit) Key(p *PendingKey) *Key

+ type Cursor struct

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

+ func (c Cursor) String() 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

+ func (g GeoPoint) Valid() bool

+ type Iterator struct

+ func (t *Iterator) Cursor() (c Cursor, err error)

+ func (t *Iterator) Next(dst interface{}) (k *Key, err error)

+ type Key struct

+ ID int64

+ Kind string

+ Name string

+ Namespace string

+ Parent *Key

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

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

+ func IncompleteKey(kind string, parent *Key) *Key

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

+ func (k *Key) Encode() string

+ func (k *Key) Equal(o *Key) bool

+ func (k *Key) GobDecode(buf []byte) error

+ func (k *Key) GobEncode() ([]byte, error)

+ func (k *Key) Incomplete() bool

+ func (k *Key) MarshalJSON() ([]byte, error)

+ func (k *Key) String() string

+ func (k *Key) UnmarshalJSON(buf []byte) error

+ type KeyLoader interface

+ LoadKey func(k *Key) error

+ type MultiError []error

+ func (m MultiError) Error() string

+ type Mutation struct

+ func NewDelete(k *Key) *Mutation

+ func NewInsert(k *Key, src interface{}) *Mutation

+ func NewUpdate(k *Key, src interface{}) *Mutation

+ func NewUpsert(k *Key, src interface{}) *Mutation

+ type PendingKey struct

+ type Property struct

+ Name string

+ NoIndex bool

+ Value interface{}

+ func SaveStruct(src interface{}) ([]Property, error)

+ type PropertyList []Property

+ func (l *PropertyList) Load(p []Property) error

+ func (l *PropertyList) Save() ([]Property, error)

+ type PropertyLoadSaver interface

+ Load func([]Property) error

+ Save func() ([]Property, error)

+ type Query struct

+ func NewQuery(kind string) *Query

+ func (q *Query) Ancestor(ancestor *Key) *Query

+ func (q *Query) Distinct() *Query

+ func (q *Query) DistinctOn(fieldNames ...string) *Query

+ func (q *Query) End(c Cursor) *Query

+ func (q *Query) EventualConsistency() *Query

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

+ func (q *Query) KeysOnly() *Query

+ func (q *Query) Limit(limit int) *Query

+ func (q *Query) Namespace(ns string) *Query

+ func (q *Query) Offset(offset int) *Query

+ func (q *Query) Order(fieldName string) *Query

+ func (q *Query) Project(fieldNames ...string) *Query

+ func (q *Query) Start(c Cursor) *Query

+ func (q *Query) Transaction(t *Transaction) *Query

+ type Transaction struct

+ func (t *Transaction) Commit() (c *Commit, err error)

+ func (t *Transaction) Delete(key *Key) error

+ func (t *Transaction) DeleteMulti(keys []*Key) (err error)

+ func (t *Transaction) Get(key *Key, dst interface{}) (err error)

+ func (t *Transaction) GetMulti(keys []*Key, dst interface{}) (err error)

+ func (t *Transaction) Mutate(muts ...*Mutation) ([]*PendingKey, error)

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

+ func (t *Transaction) PutMulti(keys []*Key, src interface{}) (ret []*PendingKey, err error)

+ func (t *Transaction) Rollback() (err error)

+ type TransactionOption interface

+ var ReadOnly TransactionOption

+ func MaxAttempts(attempts int) TransactionOption