keyvaluestorecache

Documentation

Index

• type ReadCache
  • func NewReadCache(b keyvaluestore.Backend) *ReadCache
  • func (c *ReadCache) AtomicWrite() keyvaluestore.AtomicWriteOperation
  • func (c *ReadCache) Batch() keyvaluestore.BatchOperation
  • func (c *ReadCache) Delete(key string) (success bool, err error)
  • func (c *ReadCache) Get(key string) (*string, error)
  • func (c *ReadCache) HDel(key, field string, fields ...string) error
  • func (c *ReadCache) HGet(key, field string) (*string, error)
  • func (c *ReadCache) HGetAll(key string) (map[string]string, error)
  • func (c *ReadCache) HSet(key, field string, value interface{}, fields ...keyvaluestore.KeyValue) error
  • func (c *ReadCache) HasKeyCached(key string) bool
  • func (c *ReadCache) Invalidate(key string)
  • func (c *ReadCache) InvalidateAll()
  • func (c *ReadCache) NIncrBy(key string, n int64) (int64, error)
  • func (c *ReadCache) SAdd(key string, member interface{}, members ...interface{}) error
  • func (c *ReadCache) SMembers(key string) ([]string, error)
  • func (c *ReadCache) SRem(key string, member interface{}, members ...interface{}) error
  • func (c *ReadCache) Set(key string, value interface{}) error
  • func (c *ReadCache) SetEQ(key string, value, oldValue interface{}) (bool, error)
  • func (c *ReadCache) SetNX(key string, value interface{}) (bool, error)
  • func (c *ReadCache) SetXX(key string, value interface{}) (bool, error)
  • func (c *ReadCache) Unwrap() keyvaluestore.Backend
  • func (c *ReadCache) WithBackend(b keyvaluestore.Backend) *ReadCache
  • func (c *ReadCache) WithEventuallyConsistentReads() keyvaluestore.Backend
  • func (c ReadCache) WithProfiler(profiler interface{}) keyvaluestore.Backend
  • func (c *ReadCache) ZAdd(key string, member interface{}, score float64) error
  • func (c *ReadCache) ZCount(key string, min, max float64) (int, error)
  • func (c *ReadCache) ZHAdd(key, field string, member interface{}, score float64) error
  • func (c *ReadCache) ZHGet(key, field string) (*string, error)
  • func (c *ReadCache) ZHRangeByLex(key string, min, max string, limit int) ([]string, error)
  • func (c *ReadCache) ZHRangeByScore(key string, min, max float64, limit int) ([]string, error)
  • func (c *ReadCache) ZHRangeByScoreWithScores(key string, min, max float64, limit int) (keyvaluestore.ScoredMembers, error)
  • func (c *ReadCache) ZHRem(key, field string) error
  • func (c *ReadCache) ZHRevRangeByLex(key string, min, max string, limit int) ([]string, error)
  • func (c *ReadCache) ZHRevRangeByScore(key string, min, max float64, limit int) ([]string, error)
  • func (c *ReadCache) ZHRevRangeByScoreWithScores(key string, min, max float64, limit int) (keyvaluestore.ScoredMembers, error)
  • func (c *ReadCache) ZIncrBy(key string, member interface{}, n float64) (float64, error)
  • func (c *ReadCache) ZLexCount(key string, min, max string) (int, error)
  • func (c *ReadCache) ZRangeByLex(key string, min, max string, limit int) ([]string, error)
  • func (c *ReadCache) ZRangeByScore(key string, min, max float64, limit int) ([]string, error)
  • func (c *ReadCache) ZRangeByScoreWithScores(key string, min, max float64, limit int) (keyvaluestore.ScoredMembers, error)
  • func (c *ReadCache) ZRem(key string, member interface{}) error
  • func (c *ReadCache) ZRevRangeByLex(key string, min, max string, limit int) ([]string, error)
  • func (c *ReadCache) ZRevRangeByScore(key string, min, max float64, limit int) ([]string, error)
  • func (c *ReadCache) ZRevRangeByScoreWithScores(key string, min, max float64, limit int) (keyvaluestore.ScoredMembers, error)
  • func (c *ReadCache) ZScore(key string, member interface{}) (*float64, error)

Types

type ReadCache

type ReadCache struct {
	// contains filtered or unexported fields
}

Read cache caches reads permanently, or until they're invalidated by a write operation on the cache.

func NewReadCache

func NewReadCache(b keyvaluestore.Backend) *ReadCache

func (*ReadCache) AtomicWrite

func (c *ReadCache) AtomicWrite() keyvaluestore.AtomicWriteOperation

func (*ReadCache) Batch

func (c *ReadCache) Batch() keyvaluestore.BatchOperation

func (*ReadCache) Delete

func (c *ReadCache) Delete(key string) (success bool, err error)

func (*ReadCache) Get

func (c *ReadCache) Get(key string) (*string, error)

func (*ReadCache) HDel

func (c *ReadCache) HDel(key, field string, fields ...string) error

func (*ReadCache) HGet

func (c *ReadCache) HGet(key, field string) (*string, error)

func (*ReadCache) HGetAll

func (c *ReadCache) HGetAll(key string) (map[string]string, error)

func (*ReadCache) HSet

func (c *ReadCache) HSet(key, field string, value interface{}, fields ...keyvaluestore.KeyValue) error

func (*ReadCache) HasKeyCached

func (c *ReadCache) HasKeyCached(key string) bool

func (*ReadCache) Invalidate

func (c *ReadCache) Invalidate(key string)

func (*ReadCache) InvalidateAll

func (c *ReadCache) InvalidateAll()

func (*ReadCache) NIncrBy

func (c *ReadCache) NIncrBy(key string, n int64) (int64, error)

func (*ReadCache) SAdd

func (c *ReadCache) SAdd(key string, member interface{}, members ...interface{}) error

func (*ReadCache) SMembers

func (c *ReadCache) SMembers(key string) ([]string, error)

func (*ReadCache) SRem

func (c *ReadCache) SRem(key string, member interface{}, members ...interface{}) error

func (*ReadCache) Set

func (c *ReadCache) Set(key string, value interface{}) error

func (*ReadCache) SetEQ

func (c *ReadCache) SetEQ(key string, value, oldValue interface{}) (bool, error)

func (*ReadCache) SetNX

func (c *ReadCache) SetNX(key string, value interface{}) (bool, error)

func (*ReadCache) SetXX

func (c *ReadCache) SetXX(key string, value interface{}) (bool, error)

func (*ReadCache) Unwrap

func (c *ReadCache) Unwrap() keyvaluestore.Backend

func (*ReadCache) WithBackend

func (c *ReadCache) WithBackend(b keyvaluestore.Backend) *ReadCache

Returns a new ReadCache that shares the receiver's underlying cache.

func (*ReadCache) WithEventuallyConsistentReads

func (c *ReadCache) WithEventuallyConsistentReads() keyvaluestore.Backend

Returns a new ReadCache suitable for eventually consistent reads. Reads on the returned cache will not impact the reads of ancestors with strong consistency. Additionally, the cache will take advantage of the fact that items that would have been invalidated by writes may still be returned for eventually consistent reads.

func (ReadCache) WithProfiler

func (c ReadCache) WithProfiler(profiler interface{}) keyvaluestore.Backend

func (*ReadCache) ZAdd

func (c *ReadCache) ZAdd(key string, member interface{}, score float64) error

func (*ReadCache) ZCount

func (c *ReadCache) ZCount(key string, min, max float64) (int, error)

func (*ReadCache) ZHAdd

func (c *ReadCache) ZHAdd(key, field string, member interface{}, score float64) error

func (*ReadCache) ZHGet

func (c *ReadCache) ZHGet(key, field string) (*string, error)

func (*ReadCache) ZHRangeByLex

func (c *ReadCache) ZHRangeByLex(key string, min, max string, limit int) ([]string, error)

func (*ReadCache) ZHRangeByScore

func (c *ReadCache) ZHRangeByScore(key string, min, max float64, limit int) ([]string, error)

func (*ReadCache) ZHRangeByScoreWithScores

func (c *ReadCache) ZHRangeByScoreWithScores(key string, min, max float64, limit int) (keyvaluestore.ScoredMembers, error)

func (*ReadCache) ZHRem

func (c *ReadCache) ZHRem(key, field string) error

func (*ReadCache) ZHRevRangeByLex

func (c *ReadCache) ZHRevRangeByLex(key string, min, max string, limit int) ([]string, error)

func (*ReadCache) ZHRevRangeByScore

func (c *ReadCache) ZHRevRangeByScore(key string, min, max float64, limit int) ([]string, error)

func (*ReadCache) ZHRevRangeByScoreWithScores

func (c *ReadCache) ZHRevRangeByScoreWithScores(key string, min, max float64, limit int) (keyvaluestore.ScoredMembers, error)

func (*ReadCache) ZIncrBy

func (c *ReadCache) ZIncrBy(key string, member interface{}, n float64) (float64, error)

func (*ReadCache) ZLexCount

func (c *ReadCache) ZLexCount(key string, min, max string) (int, error)

func (*ReadCache) ZRangeByLex

func (c *ReadCache) ZRangeByLex(key string, min, max string, limit int) ([]string, error)

func (*ReadCache) ZRangeByScore

func (c *ReadCache) ZRangeByScore(key string, min, max float64, limit int) ([]string, error)

func (*ReadCache) ZRangeByScoreWithScores

func (c *ReadCache) ZRangeByScoreWithScores(key string, min, max float64, limit int) (keyvaluestore.ScoredMembers, error)

func (*ReadCache) ZRem

func (c *ReadCache) ZRem(key string, member interface{}) error

func (*ReadCache) ZRevRangeByLex

func (c *ReadCache) ZRevRangeByLex(key string, min, max string, limit int) ([]string, error)

func (*ReadCache) ZRevRangeByScore

func (c *ReadCache) ZRevRangeByScore(key string, min, max float64, limit int) ([]string, error)

func (*ReadCache) ZRevRangeByScoreWithScores

func (c *ReadCache) ZRevRangeByScoreWithScores(key string, min, max float64, limit int) (keyvaluestore.ScoredMembers, error)

func (*ReadCache) ZScore

func (c *ReadCache) ZScore(key string, member interface{}) (*float64, error)