shared

package
v1.8.2 Latest Latest
Warning

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

Go to latest
Published: Jul 12, 2022 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DeleteMultiOps

func DeleteMultiOps(ctx context.Context, keys []datastore.Key, ops deleteOps) error

func GetAllOps

func GetAllOps(ctx context.Context, qDump *datastore.QueryDump, dst interface{}, ops getAllOps) ([]datastore.Key, error)

func GetMultiOps

func GetMultiOps(ctx context.Context, keys []datastore.Key, dst interface{}, ops getOps) error

func NextOps

func NextOps(ctx context.Context, qDump *datastore.QueryDump, dst interface{}, ops nextOps) (datastore.Key, error)

func PutMultiOps

func PutMultiOps(ctx context.Context, keys []datastore.Key, src interface{}, ops putOps) ([]datastore.Key, []datastore.PendingKey, error)

Types

type MiddlewareBridge added in v0.11.0

type MiddlewareBridge struct {
	Info *datastore.MiddlewareInfo
	// contains filtered or unexported fields
}

func (*MiddlewareBridge) AllocateIDs added in v0.14.0

func (cb *MiddlewareBridge) AllocateIDs(info *datastore.MiddlewareInfo, keys []datastore.Key) ([]datastore.Key, error)

func (*MiddlewareBridge) Count added in v0.14.0

func (*MiddlewareBridge) DeleteMultiWithTx added in v0.11.0

func (cb *MiddlewareBridge) DeleteMultiWithTx(info *datastore.MiddlewareInfo, keys []datastore.Key) error

func (*MiddlewareBridge) DeleteMultiWithoutTx added in v0.11.0

func (cb *MiddlewareBridge) DeleteMultiWithoutTx(info *datastore.MiddlewareInfo, keys []datastore.Key) error

func (*MiddlewareBridge) GetAll added in v0.11.0

func (*MiddlewareBridge) GetMultiWithTx added in v0.11.0

func (cb *MiddlewareBridge) GetMultiWithTx(info *datastore.MiddlewareInfo, keys []datastore.Key, psList []datastore.PropertyList) error

func (*MiddlewareBridge) GetMultiWithoutTx added in v0.11.0

func (cb *MiddlewareBridge) GetMultiWithoutTx(info *datastore.MiddlewareInfo, keys []datastore.Key, psList []datastore.PropertyList) error

func (*MiddlewareBridge) Next added in v0.11.0

func (*MiddlewareBridge) PostCommit added in v0.11.0

func (*MiddlewareBridge) PostRollback added in v0.11.0

func (*MiddlewareBridge) PutMultiWithTx added in v0.11.0

func (cb *MiddlewareBridge) PutMultiWithTx(info *datastore.MiddlewareInfo, keys []datastore.Key, psList []datastore.PropertyList) ([]datastore.PendingKey, error)

func (*MiddlewareBridge) PutMultiWithoutTx added in v0.11.0

func (cb *MiddlewareBridge) PutMultiWithoutTx(info *datastore.MiddlewareInfo, keys []datastore.Key, psList []datastore.PropertyList) ([]datastore.Key, error)

func (*MiddlewareBridge) Run added in v0.11.0

type OriginalClientBridge

type OriginalClientBridge interface {
	AllocateIDs(ctx context.Context, keys []datastore.Key) ([]datastore.Key, error)
	PutMulti(ctx context.Context, keys []datastore.Key, psList []datastore.PropertyList) ([]datastore.Key, error)
	GetMulti(ctx context.Context, keys []datastore.Key, psList []datastore.PropertyList) error
	DeleteMulti(ctx context.Context, keys []datastore.Key) error
	Run(ctx context.Context, q datastore.Query, qDump *datastore.QueryDump) datastore.Iterator
	GetAll(ctx context.Context, q datastore.Query, qDump *datastore.QueryDump, psList *[]datastore.PropertyList) ([]datastore.Key, error)
	Count(ctx context.Context, q datastore.Query, qDump *datastore.QueryDump) (int, error)
}

type OriginalIteratorBridge

type OriginalIteratorBridge interface {
	Next(iter datastore.Iterator, ps *datastore.PropertyList) (datastore.Key, error)
}

type OriginalTransactionBridge

type OriginalTransactionBridge interface {
	PutMulti(keys []datastore.Key, psList []datastore.PropertyList) ([]datastore.PendingKey, error)
	GetMulti(keys []datastore.Key, psList []datastore.PropertyList) error
	DeleteMulti(keys []datastore.Key) error
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL