shared

Documentation

Index

• func DeleteMultiOps(ctx context.Context, keys []datastore.Key, ops deleteOps) error
• func GetAllOps(ctx context.Context, qDump *datastore.QueryDump, dst interface{}, ...) ([]datastore.Key, error)
• func GetMultiOps(ctx context.Context, keys []datastore.Key, dst interface{}, ops getOps) error
• func NextOps(ctx context.Context, qDump *datastore.QueryDump, dst interface{}, ops nextOps) (datastore.Key, error)
• func PutMultiOps(ctx context.Context, keys []datastore.Key, src interface{}, ops putOps) ([]datastore.Key, []datastore.PendingKey, error)
• type CacheBridge
  • func NewCacheBridge(info *datastore.CacheInfo, ocb OriginalClientBridge, ...) *CacheBridge
  • func (cb *CacheBridge) DeleteMultiWithTx(info *datastore.CacheInfo, keys []datastore.Key) error
  • func (cb *CacheBridge) DeleteMultiWithoutTx(info *datastore.CacheInfo, keys []datastore.Key) error
  • func (cb *CacheBridge) GetAll(info *datastore.CacheInfo, q datastore.Query, qDump *datastore.QueryDump, ...) ([]datastore.Key, error)
  • func (cb *CacheBridge) GetMultiWithTx(info *datastore.CacheInfo, keys []datastore.Key, ...) error
  • func (cb *CacheBridge) GetMultiWithoutTx(info *datastore.CacheInfo, keys []datastore.Key, ...) error
  • func (cb *CacheBridge) Next(info *datastore.CacheInfo, q datastore.Query, qDump *datastore.QueryDump, ...) (datastore.Key, error)
  • func (cb *CacheBridge) PostCommit(info *datastore.CacheInfo, tx datastore.Transaction, commit datastore.Commit) error
  • func (cb *CacheBridge) PostRollback(info *datastore.CacheInfo, tx datastore.Transaction) error
  • func (cb *CacheBridge) PutMultiWithTx(info *datastore.CacheInfo, keys []datastore.Key, ...) ([]datastore.PendingKey, error)
  • func (cb *CacheBridge) PutMultiWithoutTx(info *datastore.CacheInfo, keys []datastore.Key, ...) ([]datastore.Key, error)
  • func (cb *CacheBridge) Run(info *datastore.CacheInfo, q datastore.Query, qDump *datastore.QueryDump) datastore.Iterator
• type OriginalClientBridge
• type OriginalIteratorBridge
• type OriginalTransactionBridge

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 NewCacheBridge

func NewCacheBridge(info *datastore.CacheInfo, ocb OriginalClientBridge, otb OriginalTransactionBridge, oib OriginalIteratorBridge, cs []datastore.CacheStrategy) *CacheBridge

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 (cb *CacheBridge) GetAll(info *datastore.CacheInfo, q datastore.Query, qDump *datastore.QueryDump, psList *[]datastore.PropertyList) ([]datastore.Key, error)

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 (cb *CacheBridge) Next(info *datastore.CacheInfo, q datastore.Query, qDump *datastore.QueryDump, iter datastore.Iterator, ps *datastore.PropertyList) (datastore.Key, error)

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

func (cb *CacheBridge) Run(info *datastore.CacheInfo, q datastore.Query, qDump *datastore.QueryDump) datastore.Iterator

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
}