cache

README

cache

Documentation

Index

• func Decode(data []byte, i interface{}) error
• func Encode(i interface{}) ([]byte, error)
• type Cache
  • func NewRedisCache(clt conn.RedisClient) Cache
• type CacheMapObj
• type CacheObj
• type ComCacheObj
  • func (t *ComCacheObj) DecodePipe(obj CacheObj) error
  • func (s *ComCacheObj) GetError() error
  • func (s *ComCacheObj) GetExpiredTime() time.Duration
  • func (s *ComCacheObj) GetStringCmd() (*redis.StringCmd, error)
  • func (s *ComCacheObj) HasError() bool
  • func (s *ComCacheObj) SetExpiredTime(d time.Duration)
  • func (s *ComCacheObj) SetStringCmd(sc *redis.StringCmd)

Functions

func Decode

func Decode(data []byte, i interface{}) error

func Encode

func Encode(i interface{}) ([]byte, error)

Types

type Cache

type Cache interface {
	SaveObjs(exp time.Duration, docs ...CacheObj) error
	SaveObj(i CacheObj, exp time.Duration) error
	GetObj(key string, i CacheObj) error
	GetObjs(keys []string, d CacheObj) (objs []CacheObj, err error)
	SaveObjHash(i CacheMapObj, exp time.Duration) error
	GetObjHash(key string, i CacheMapObj) error
}

func NewRedisCache

func NewRedisCache(clt conn.RedisClient) Cache

type CacheMapObj

type CacheMapObj interface {
	GetKey() string
	EncodeMap() (map[string]string, error)
	DecodeMap(map[string]string) error
	SetExpiredTime(d time.Duration)
	GetExpiredTime() time.Duration
}

type CacheObj

type CacheObj interface {
	GetKey() string
	Encode() ([]byte, error)
	SetStringCmd(sc *redis.StringCmd)
	Decode([]byte) error
	DecodePipe() error
	GetError() error
	HasError() bool
	SetExpiredTime(d time.Duration)
	GetExpiredTime() time.Duration
}

type ComCacheObj

type ComCacheObj struct {
	E time.Duration
	// contains filtered or unexported fields
}

func (*ComCacheObj) DecodePipe

func (t *ComCacheObj) DecodePipe(obj CacheObj) error

func (*ComCacheObj) GetError

func (s *ComCacheObj) GetError() error

func (*ComCacheObj) GetExpiredTime

func (s *ComCacheObj) GetExpiredTime() time.Duration

func (*ComCacheObj) GetStringCmd

func (s *ComCacheObj) GetStringCmd() (*redis.StringCmd, error)

func (*ComCacheObj) HasError

func (s *ComCacheObj) HasError() bool

func (*ComCacheObj) SetExpiredTime

func (s *ComCacheObj) SetExpiredTime(d time.Duration)

func (*ComCacheObj) SetStringCmd

func (s *ComCacheObj) SetStringCmd(sc *redis.StringCmd)