cache

Mar 8, 2024

Changes in this version

type Cache

+ GetBytes func(key string) ([]byte, error)

type CacheManager

+ func (self *CacheManager) GetBytes(key string) ([]byte, error)

type LocalMapManager

+ func (self *LocalMapManager) GetBytes(key string) ([]byte, error)

type RedisManager

+ func (self *RedisManager) GetBytes(key string) ([]byte, error)

Feb 29, 2024

Changes in this version

type LocalMapManager

+ func (self *LocalMapManager) Values(pattern ...string) ([]interface{}, error)

May 17, 2023

Changes in this version

type Cache

+ Exists func(key string) (bool, error)

type CacheManager

+ func (self *CacheManager) Exists(key string) (bool, error)

type LocalMapManager

+ func (self *LocalMapManager) Exists(key string) (bool, error)

type RedisManager

+ func (self *RedisManager) Exists(key string) (bool, error)

Sep 11, 2022

Changes in this version

+ func SpinLocker(lockObj, errorMsg string, trySecond, expSecond int, callObj func() error) error

+ func TryLocker(lockObj, errorMsg string, expSecond int, callObj func() error) error

+ type Cache interface

+ Brpop func(key string, expire int64, result interface{}) error

+ BrpopBool func(key string, expire int64) (bool, error)

+ BrpopFloat64 func(key string, expire int64) (float64, error)

+ BrpopInt64 func(key string, expire int64) (int64, error)

+ BrpopString func(key string, expire int64) (string, error)

+ Del func(input ...string) error

+ Flush func() error

+ Get func(key string, input interface{}) (interface{}, bool, error)

+ GetBool func(key string) (bool, error)

+ GetFloat64 func(key string) (float64, error)

+ GetInt64 func(key string) (int64, error)

+ GetString func(key string) (string, error)

+ Keys func(pattern ...string) ([]string, error)

+ LuaScript func(script string, key []string, val ...interface{}) (interface{}, error)

+ Publish func(key string, val interface{}) error

+ Put func(key string, input interface{}, expire ...int) error

+ PutBatch func(objs ...*PutObj) error

+ Rpush func(key string, val interface{}) error

+ Size func(pattern ...string) (int, error)

+ Subscribe func(key string, timeout int, call func(msg string) (bool, error)) error

+ Values func(pattern ...string) ([]interface{}, error)

+ func NewLocalCache(a, b int) Cache

+ type CacheManager struct

+ func (self *CacheManager) Brpop(key string, expire int64, result interface{}) error

+ func (self *CacheManager) BrpopBool(key string, expire int64) (bool, error)

+ func (self *CacheManager) BrpopFloat64(key string, expire int64) (float64, error)

+ func (self *CacheManager) BrpopInt64(key string, expire int64) (int64, error)

+ func (self *CacheManager) BrpopString(key string, expire int64) (string, error)

+ func (self *CacheManager) Del(key ...string) error

+ func (self *CacheManager) Flush() error

+ func (self *CacheManager) Get(key string, input interface{}) (interface{}, bool, error)

+ func (self *CacheManager) GetBool(key string) (bool, error)

+ func (self *CacheManager) GetFloat64(key string) (float64, error)

+ func (self *CacheManager) GetInt64(key string) (int64, error)

+ func (self *CacheManager) GetString(key string) (string, error)

+ func (self *CacheManager) Keys(pattern ...string) ([]string, error)

+ func (self *CacheManager) LuaScript(script string, key []string, val ...interface{}) (interface{}, error)

+ func (self *CacheManager) Publish(key string, val interface{}) error

+ func (self *CacheManager) Put(key string, input interface{}, expire ...int) error

+ func (self *CacheManager) PutBatch(objs ...*PutObj) error

+ func (self *CacheManager) Rpush(key string, val interface{}) error

+ func (self *CacheManager) Size(pattern ...string) (int, error)

+ func (self *CacheManager) Subscribe(key string, timeout int, call func(msg string) (bool, error)) error

+ func (self *CacheManager) Values(pattern ...string) ([]interface{}, error)

+ type LocalMapManager struct

+ func (self *LocalMapManager) Del(key ...string) error

+ func (self *LocalMapManager) Flush() error

+ func (self *LocalMapManager) Get(key string, input interface{}) (interface{}, bool, error)

+ func (self *LocalMapManager) GetBool(key string) (bool, error)

+ func (self *LocalMapManager) GetFloat64(key string) (float64, error)

+ func (self *LocalMapManager) GetInt64(key string) (int64, error)

+ func (self *LocalMapManager) GetString(key string) (string, error)

+ func (self *LocalMapManager) NewCache(a, b int) Cache

+ func (self *LocalMapManager) Put(key string, input interface{}, expire ...int) error

+ func (self *LocalMapManager) Size(pattern ...string) (int, error)

+ type Lock struct

+ type PutObj struct

+ Expire int

+ Key string

+ Value interface{}

+ type RedisConfig struct

+ DsName string

+ Host string

+ IdleTimeout int

+ MaxActive int

+ MaxIdle int

+ Network string

+ Password string

+ Port int

+ type RedisManager struct

+ DsName string

+ Pool *redis.Pool

+ func NewRedis(ds ...string) (*RedisManager, error)

+ func (self *RedisManager) Brpop(key string, expire int64, result interface{}) error

+ func (self *RedisManager) BrpopBool(key string, expire int64) (bool, error)

+ func (self *RedisManager) BrpopFloat64(key string, expire int64) (float64, error)

+ func (self *RedisManager) BrpopInt64(key string, expire int64) (int64, error)

+ func (self *RedisManager) BrpopString(key string, expire int64) (string, error)

+ func (self *RedisManager) Client(ds ...string) (*RedisManager, error)

+ func (self *RedisManager) Close(conn redis.Conn)

+ func (self *RedisManager) Del(key ...string) error

+ func (self *RedisManager) Flush() error

+ func (self *RedisManager) Get(key string, input interface{}) (interface{}, bool, error)

+ func (self *RedisManager) GetBool(key string) (bool, error)

+ func (self *RedisManager) GetFloat64(key string) (float64, error)

+ func (self *RedisManager) GetInt64(key string) (int64, error)

+ func (self *RedisManager) GetString(key string) (string, error)

+ func (self *RedisManager) InitConfig(input ...RedisConfig) (*RedisManager, error)

+ func (self *RedisManager) Keys(pattern ...string) ([]string, error)

+ func (self *RedisManager) LuaScript(cmd string, key []string, val ...interface{}) (interface{}, error)

+ func (self *RedisManager) Publish(key string, val interface{}) error

+ func (self *RedisManager) Put(key string, input interface{}, expire ...int) error

+ func (self *RedisManager) PutBatch(objs ...*PutObj) error

+ func (self *RedisManager) Rpush(key string, val interface{}) error

+ func (self *RedisManager) Size(pattern ...string) (int, error)

+ func (self *RedisManager) SpinLockWithTimeout(resource string, trySecond, expSecond int, call func() error) error

+ func (self *RedisManager) Subscribe(key string, expSecond int, call func(msg string) (bool, error)) error

+ func (self *RedisManager) TryLockWithTimeout(resource string, expSecond int, call func() error) error

+ func (self *RedisManager) Values(pattern ...string) ([]interface{}, error)