store

README

store

易用的链式存储kv store
避免在缓存与持久化里沉沦, 减少心智负担

read
-> memory
    -> redis
        -> [kvdb/asw s3]

write
-> [kvdb/asw s3]
    -> redis
        -> memory

Documentation

Index

• func InitStore(bucket string, store Store)
• type KeysInfo
• type KeysInfoSlice
  • func (s KeysInfoSlice) ToKeys() (result []string)
• type StSlice
  • func (s StSlice) Range(cb func(Store) bool)
  • func (s StSlice) RevRange(cb func(Store) bool)
• type Store
  • func Get(bucket string) Store
  • func NewChain(store ...Store) Store

Functions

func InitStore

func InitStore(bucket string, store Store)

Types

type KeysInfo

type KeysInfo struct {
	Key  string
	Size int64
}

type KeysInfoSlice

type KeysInfoSlice []KeysInfo

func (KeysInfoSlice) ToKeys

func (s KeysInfoSlice) ToKeys() (result []string)

type StSlice

type StSlice []Store

func (StSlice) Range

func (s StSlice) Range(cb func(Store) bool)

func (StSlice) RevRange

func (s StSlice) RevRange(cb func(Store) bool)

type Store

type Store interface {
	Close() error
	Put(key string, value []byte) error
	PutTTL(key string, value []byte, ttl time.Duration) error
	Get(key string) ([]byte, error)

	TTL(key string) (time.Duration, error)

	RPut(key string, r io.Reader, size int64) error
	RPutTTL(key string, r io.Reader, size int64, ttl time.Duration) error
	RGet(key string) (io.Reader, error)

	Exist(key string) (bool, error)
	Delete(key string) error

	RangeKeys(prefix, limit string, max int) (KeysInfoSlice, error)
	Range(prefix, limit string, cb func(key string, value []byte) bool) error
	RRange(prefix, limit string, cb func(key string, r io.Reader) bool) error
}

func Get

func Get(bucket string) Store

func NewChain

func NewChain(store ...Store) Store

NewChain 存储链