datastore

package
v0.0.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 5, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CountForQuery added in v0.0.7 

func CountForQuery(ctx context.Context, client *datastore.Client, query *datastore.Query) (count int, err error)

func Exists 

func Exists(ctx context.Context, client *datastore.Client, key *datastore.Key) (exists bool, err error)

func NewClient 

func NewClient(ctx context.Context, projectID, databaseID string, options ...option.ClientOption) (client *datastore.Client, err error)

func NewCursorCodecs 

func NewCursorCodecs(secret string) (encoder func(*datastore.Cursor) (string, error), decoder func(string) (*datastore.Cursor, error))

func Query added in v0.0.7 

func Query[E any](ctx context.Context, client *datastore.Client, query *datastore.Query) (entities []*E, err error)

func QueryKeys added in v0.0.7 

func QueryKeys(ctx context.Context, client *datastore.Client, query *datastore.Query) (keys []*datastore.Key, cursor *datastore.Cursor, err error)

func QueryOne added in v0.0.7 

func QueryOne[E any](ctx context.Context, client *datastore.Client, query *datastore.Query) (entity *E, err error)

Types

type CRUD added in v0.0.7 

type CRUD[E any] interface {
	Client() *datastore.Client
	Exists(ctx context.Context, key *datastore.Key) (exists bool, err error)
	Create(ctx context.Context, key *datastore.Key, entity *E) (*datastore.Key, error)
	CreateTx(tx *datastore.Transaction, key *datastore.Key, entity *E) (*datastore.PendingKey, error)
	CreateBatch(ctx context.Context, keys []*datastore.Key, entities []*E) ([]*datastore.Key, error)
	CreateBatchTx(tx *datastore.Transaction, keys []*datastore.Key, entities []*E) ([]*datastore.PendingKey, error)
	Read(ctx context.Context, key *datastore.Key) (entity *E, err error)
	ReadTx(tx *datastore.Transaction, key *datastore.Key) (entity *E, err error)
	ReadBatch(ctx context.Context, keys []*datastore.Key) (entities []*E, err error)
	ReadBatchTx(tx *datastore.Transaction, keys []*datastore.Key) (entities []*E, err error)
	ListAll(ctx context.Context, kind string, ancestor *datastore.Key) (entities []*E, err error)
	ListAllKeys(ctx context.Context, kind string, ancestor *datastore.Key) (keys []*datastore.Key, err error)
	Count(ctx context.Context, kind string, ancestor *datastore.Key) (count int, err error)
	Update(ctx context.Context, key *datastore.Key, entity *E) error
	UpdateTx(tx *datastore.Transaction, key *datastore.Key, entity *E) error
	UpdateBatch(ctx context.Context, keys []*datastore.Key, entities []*E) error
	UpdateBatchTx(tx *datastore.Transaction, keys []*datastore.Key, entities []*E) error
	Delete(ctx context.Context, key *datastore.Key) error
	DeleteTx(tx *datastore.Transaction, key *datastore.Key) error
	DeleteBatch(ctx context.Context, keys []*datastore.Key) error
	DeleteBatchTx(tx *datastore.Transaction, keys []*datastore.Key) error
}

func NewCRUDRepo added in v0.0.7 

func NewCRUDRepo[E any](client *datastore.Client) CRUD[E]

type CRUDRepo added in v0.0.7 

type CRUDRepo[E any] struct {
	// contains filtered or unexported fields
}

func (*CRUDRepo[E]) Client added in v0.0.7 

func (r *CRUDRepo[E]) Client() *datastore.Client

func (*CRUDRepo[E]) Count added in v0.0.7 

func (r *CRUDRepo[E]) Count(ctx context.Context, kind string, ancestor *datastore.Key) (int, error)

func (*CRUDRepo[E]) Create added in v0.0.7 

func (r *CRUDRepo[E]) Create(ctx context.Context, key *datastore.Key, entity *E) (*datastore.Key, error)

func (*CRUDRepo[E]) CreateBatch added in v0.0.7 

func (r *CRUDRepo[E]) CreateBatch(ctx context.Context, keys []*datastore.Key, entities []*E) ([]*datastore.Key, error)

func (*CRUDRepo[E]) CreateBatchTx added in v0.0.7 

func (r *CRUDRepo[E]) CreateBatchTx(tx *datastore.Transaction, keys []*datastore.Key, entities []*E) ([]*datastore.PendingKey, error)

func (*CRUDRepo[E]) CreateTx added in v0.0.7 

func (r *CRUDRepo[E]) CreateTx(tx *datastore.Transaction, key *datastore.Key, entity *E) (*datastore.PendingKey, error)

func (*CRUDRepo[E]) Delete added in v0.0.7 

func (r *CRUDRepo[E]) Delete(ctx context.Context, key *datastore.Key) error

func (*CRUDRepo[E]) DeleteBatch added in v0.0.7 

func (r *CRUDRepo[E]) DeleteBatch(ctx context.Context, keys []*datastore.Key) error

func (*CRUDRepo[E]) DeleteBatchTx added in v0.0.7 

func (r *CRUDRepo[E]) DeleteBatchTx(tx *datastore.Transaction, keys []*datastore.Key) error

func (*CRUDRepo[E]) DeleteTx added in v0.0.7 

func (r *CRUDRepo[E]) DeleteTx(tx *datastore.Transaction, key *datastore.Key) error

func (*CRUDRepo[E]) Exists added in v0.0.7 

func (r *CRUDRepo[E]) Exists(ctx context.Context, key *datastore.Key) (exists bool, err error)

func (*CRUDRepo[E]) ListAll added in v0.0.7 

func (r *CRUDRepo[E]) ListAll(ctx context.Context, kind string, ancestor *datastore.Key) (entities []*E, err error)

func (*CRUDRepo[E]) ListAllKeys added in v0.0.7 

func (r *CRUDRepo[E]) ListAllKeys(ctx context.Context, kind string, ancestor *datastore.Key) (keys []*datastore.Key, err error)

func (*CRUDRepo[E]) Read added in v0.0.7 

func (r *CRUDRepo[E]) Read(ctx context.Context, key *datastore.Key) (entity *E, err error)

func (*CRUDRepo[E]) ReadBatch added in v0.0.7 

func (r *CRUDRepo[E]) ReadBatch(ctx context.Context, keys []*datastore.Key) (entities []*E, err error)

func (*CRUDRepo[E]) ReadBatchTx added in v0.0.7 

func (r *CRUDRepo[E]) ReadBatchTx(tx *datastore.Transaction, keys []*datastore.Key) (entities []*E, err error)

func (*CRUDRepo[E]) ReadTx added in v0.0.7 

func (r *CRUDRepo[E]) ReadTx(tx *datastore.Transaction, key *datastore.Key) (entity *E, err error)

func (*CRUDRepo[E]) Update added in v0.0.7 

func (r *CRUDRepo[E]) Update(ctx context.Context, key *datastore.Key, entity *E) error

func (*CRUDRepo[E]) UpdateBatch added in v0.0.7 

func (r *CRUDRepo[E]) UpdateBatch(ctx context.Context, keys []*datastore.Key, entities []*E) error

func (*CRUDRepo[E]) UpdateBatchTx added in v0.0.7 

func (r *CRUDRepo[E]) UpdateBatchTx(tx *datastore.Transaction, keys []*datastore.Key, entities []*E) error

func (*CRUDRepo[E]) UpdateTx added in v0.0.7 

func (r *CRUDRepo[E]) UpdateTx(tx *datastore.Transaction, key *datastore.Key, entity *E) error

Source Files

View all Source files

Directories

Path Synopsis
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.