shared

package
v0.8.1 Latest Latest
Warning

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

Go to latest
Published: Dec 5, 2017 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 CacheBridge

type CacheBridge struct {
	Info *datastore.CacheInfo
	// contains filtered or unexported fields
}

func (*CacheBridge) DeleteMultiWithTx

func (cb *CacheBridge) DeleteMultiWithTx(info *datastore.CacheInfo, keys []datastore.Key) error

func (*CacheBridge) DeleteMultiWithoutTx

func (cb *CacheBridge) DeleteMultiWithoutTx(info *datastore.CacheInfo, keys []datastore.Key) error

func (*CacheBridge) GetAll

func (*CacheBridge) GetMultiWithTx

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

func (*CacheBridge) GetMultiWithoutTx

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

func (*CacheBridge) Next

func (*CacheBridge) PostCommit

func (cb *CacheBridge) PostCommit(info *datastore.CacheInfo, tx datastore.Transaction, commit datastore.Commit) error

func (*CacheBridge) PostRollback

func (cb *CacheBridge) PostRollback(info *datastore.CacheInfo, tx datastore.Transaction) error

func (*CacheBridge) PutMultiWithTx

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

func (*CacheBridge) PutMultiWithoutTx

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

func (*CacheBridge) Run

type OriginalClientBridge

type OriginalClientBridge interface {
	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)
}

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