ds

type Cache interface {
	// AddMulti adds items if keys are not in use. Returns ErrNotStored on conflict.
	AddMulti(ctx context.Context, items []*Item) error

	// CompareAndSwapMulti updates items if unchanged since Get. Returns ErrCASConflict or ErrNotStored.
	CompareAndSwapMulti(ctx context.Context, items []*Item) error

	// DeleteMulti removes keys.
	DeleteMulti(ctx context.Context, keys []string) error

	// GetMulti fetches keys. Returns map of found items. No error on miss.
	GetMulti(ctx context.Context, keys []string) (map[string]*Item, error)

	// SetMulti sets items blindly. Returns error per item on failure.
	SetMulti(ctx context.Context, items []*Item) error

	// Increment atomically increments a key's integer value by delta.
	// Returns the new value after incrementing. Creates the key with
	// value=delta and the given expiration if the key does not exist.
	Increment(ctx context.Context, key string, delta int64, expiration time.Duration) (int64, error)
}

type Client struct {
	Store
	// contains filtered or unexported fields
}

type ClientOption func(*Client)

type CloudAccess interface {
	DatastoreClient() *datastore.Client
}

type Filter struct {
	Field string
	Op    string
	Value interface{}
}

type Item struct {
	Key        string
	Value      []byte
	Flags      uint32
	Expiration time.Duration
	// contains filtered or unexported fields
}

type Iterator interface {
	Next(dst interface{}) (*datastore.Key, error)
	Cursor() (string, error)
}

type LocalAccess interface {
	DB(namespace string) (*sql.DB, error)
}

type MultiError []error

type Mutation struct {
	// contains filtered or unexported fields
}

type Mutator interface {
	Mutate(ctx context.Context, muts ...*datastore.Mutation) ([]*datastore.Key, error)
}

type OnErrorFunc func(ctx context.Context, err error)

type Order struct {
	Field     string
	Direction string // "asc" or "desc"
}

type Query interface {
	Kind() string
	Filters() []Filter
	Orders() []Order
	GetLimit() int
	GetOffset() int
	IsKeysOnly() bool
	GetAncestor() *datastore.Key
	GetCursor() string
	GetNamespace() string
}

type Store interface {
	Get(ctx context.Context, key *datastore.Key, dst interface{}) error
	GetMulti(ctx context.Context, keys []*datastore.Key, dst interface{}) error
	Put(ctx context.Context, key *datastore.Key, src interface{}) (*datastore.Key, error)
	PutMulti(ctx context.Context, keys []*datastore.Key, src interface{}) ([]*datastore.Key, error)
	Delete(ctx context.Context, key *datastore.Key) error
	DeleteMulti(ctx context.Context, keys []*datastore.Key) error
	Run(ctx context.Context, q Query) Iterator
	NewTransaction(ctx context.Context, opts ...datastore.TransactionOption) (TransactionStore, error)
	RunInTransaction(ctx context.Context, f func(tx TransactionStore) error, opts ...datastore.TransactionOption) (*datastore.Commit, error)
	Close() error
}

type Transaction struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type TransactionMutator interface {
	Mutate(muts ...*datastore.Mutation) ([]*datastore.PendingKey, error)
}

type TransactionStore interface {
	Get(key *datastore.Key, dst interface{}) error
	GetMulti(keys []*datastore.Key, dst interface{}) error
	Put(key *datastore.Key, src interface{}) (*datastore.PendingKey, error)
	PutMulti(keys []*datastore.Key, src interface{}) ([]*datastore.PendingKey, error)
	Delete(key *datastore.Key) error
	DeleteMulti(keys []*datastore.Key) error
	Commit() (*datastore.Commit, error)
	Rollback() error
}