datastore: go.mercari.io/datastore/internal/shared Index | Files

package shared

import "go.mercari.io/datastore/internal/shared"

Index

Package Files

doc.go middleware_bridge.go ops.go

func DeleteMultiOps Uses

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

func GetAllOps Uses

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

func GetMultiOps Uses

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

func NextOps Uses

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

func PutMultiOps Uses

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

type MiddlewareBridge Uses

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

func NewCacheBridge Uses

func NewCacheBridge(info *datastore.MiddlewareInfo, ocb OriginalClientBridge, otb OriginalTransactionBridge, oib OriginalIteratorBridge, mws []datastore.Middleware) *MiddlewareBridge

func (*MiddlewareBridge) AllocateIDs Uses

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

func (*MiddlewareBridge) Count Uses

func (cb *MiddlewareBridge) Count(info *datastore.MiddlewareInfo, q datastore.Query, qDump *datastore.QueryDump) (int, error)

func (*MiddlewareBridge) DeleteMultiWithTx Uses

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

func (*MiddlewareBridge) DeleteMultiWithoutTx Uses

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

func (*MiddlewareBridge) GetAll Uses

func (cb *MiddlewareBridge) GetAll(info *datastore.MiddlewareInfo, q datastore.Query, qDump *datastore.QueryDump, psList *[]datastore.PropertyList) ([]datastore.Key, error)

func (*MiddlewareBridge) GetMultiWithTx Uses

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

func (*MiddlewareBridge) GetMultiWithoutTx Uses

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

func (*MiddlewareBridge) Next Uses

func (cb *MiddlewareBridge) Next(info *datastore.MiddlewareInfo, q datastore.Query, qDump *datastore.QueryDump, iter datastore.Iterator, ps *datastore.PropertyList) (datastore.Key, error)

func (*MiddlewareBridge) PostCommit Uses

func (cb *MiddlewareBridge) PostCommit(info *datastore.MiddlewareInfo, tx datastore.Transaction, commit datastore.Commit) error

func (*MiddlewareBridge) PostRollback Uses

func (cb *MiddlewareBridge) PostRollback(info *datastore.MiddlewareInfo, tx datastore.Transaction) error

func (*MiddlewareBridge) PutMultiWithTx Uses

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

func (*MiddlewareBridge) PutMultiWithoutTx Uses

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

func (*MiddlewareBridge) Run Uses

func (cb *MiddlewareBridge) Run(info *datastore.MiddlewareInfo, q datastore.Query, qDump *datastore.QueryDump) datastore.Iterator

type OriginalClientBridge Uses

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 Uses

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

type OriginalTransactionBridge Uses

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
}

Package shared imports 5 packages (graph) and is imported by 2 packages. Updated 2018-05-29. Refresh now. Tools for package owners.