storagecache

Documentation

Index

• func New(s Storage, opts ...CacheOption) datastore.CacheStrategy
• type CacheItem
• type CacheOption
  • func WithExcludeKinds(kinds ...string) CacheOption
  • func WithIncludeKinds(kinds ...string) CacheOption
  • func WithKeyFilter(f func(key datastore.Key) bool) CacheOption
• type Logger
• type Storage
• type TxOpLog
• type TxOps

Functions

func New

func New(s Storage, opts ...CacheOption) datastore.CacheStrategy

Types

type CacheItem

type CacheItem struct {
	Key          datastore.Key
	PropertyList datastore.PropertyList
}

type CacheOption

type CacheOption interface {
	Apply(*cacheHandler)
}

func WithExcludeKinds

func WithExcludeKinds(kinds ...string) CacheOption

func WithIncludeKinds

func WithIncludeKinds(kinds ...string) CacheOption

func WithKeyFilter

func WithKeyFilter(f func(key datastore.Key) bool) CacheOption

type Logger

type Logger interface {
	Printf(ctx context.Context, format string, args ...interface{})
}

type Storage

type Storage interface {
	SetMulti(ctx context.Context, is []*CacheItem) error
	// GetMulti returns slice of CacheItem of the same length as Keys of the argument.
	// If not in the cache, the value of the corresponding element is nil.
	GetMulti(ctx context.Context, keys []datastore.Key) ([]*CacheItem, error)
	DeleteMulti(ctx context.Context, keys []datastore.Key) error
}

type TxOpLog

type TxOpLog struct {
	Ops          TxOps
	Key          datastore.Key
	PendingKey   datastore.PendingKey
	PropertyList datastore.PropertyList
}

type TxOps

type TxOps int

const (
	TxPutOp TxOps = iota
	TxGetOp
	TxDeleteOp
)