Documentation
¶
Index ¶
- func DeleteContext(ctx context.Context, cache Cache, key string) error
- func GetContext(ctx context.Context, cache Cache, key string) interface{}
- func IsExistContext(ctx context.Context, cache Cache, key string) bool
- func SetContext(ctx context.Context, cache Cache, key string, val interface{}, ...) error
- type Cache
- type ContextCache
- type Memcache
- type Memory
- type Redis
- func (r *Redis) Delete(key string) error
- func (r *Redis) DeleteContext(ctx context.Context, key string) error
- func (r *Redis) Get(key string) interface{}
- func (r *Redis) GetContext(ctx context.Context, key string) interface{}
- func (r *Redis) IsExist(key string) bool
- func (r *Redis) IsExistContext(ctx context.Context, key string) bool
- func (r *Redis) Set(key string, val interface{}, timeout time.Duration) error
- func (r *Redis) SetConn(conn redis.UniversalClient)
- func (r *Redis) SetContext(ctx context.Context, key string, val interface{}, timeout time.Duration) error
- func (r *Redis) SetRedisCtx(ctx context.Context)
- type RedisOpts
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeleteContext ¶ added in v2.1.5
DeleteContext delete value in cache.
func GetContext ¶ added in v2.1.5
GetContext get value from cache
func IsExistContext ¶ added in v2.1.5
IsExistContext check value exists in cache.
Types ¶
type Cache ¶
type Cache interface {
Get(key string) interface{}
Set(key string, val interface{}, timeout time.Duration) error
IsExist(key string) bool
Delete(key string) error
}
Cache interface
type ContextCache ¶ added in v2.1.5
type ContextCache interface {
Cache
GetContext(ctx context.Context, key string) interface{}
SetContext(ctx context.Context, key string, val interface{}, timeout time.Duration) error
IsExistContext(ctx context.Context, key string) bool
DeleteContext(ctx context.Context, key string) error
}
ContextCache interface
type Memcache ¶
type Memcache struct {
// contains filtered or unexported fields
}
Memcache struct contains *memcache.Client
type Memory ¶
Memory struct contains *memcache.Client
type Redis ¶
type Redis struct {
// contains filtered or unexported fields
}
Redis .redis cache
func (*Redis) DeleteContext ¶ added in v2.1.5
DeleteContext 删除
func (*Redis) GetContext ¶ added in v2.1.5
GetContext 获取一个值
func (*Redis) IsExistContext ¶ added in v2.1.5
IsExistContext 判断key是否存在
func (*Redis) SetContext ¶ added in v2.1.5
func (r *Redis) SetContext(ctx context.Context, key string, val interface{}, timeout time.Duration) error
SetContext 设置一个值
func (*Redis) SetRedisCtx ¶ added in v2.1.3
SetRedisCtx 设置redis ctx 参数
type RedisOpts ¶
type RedisOpts struct {
Host string `json:"host" yaml:"host"`
Username string `json:"username" yaml:"username"`
Password string `json:"password" yaml:"password"`
Database int `json:"database" yaml:"database"`
MinIdleConns int `json:"min_idle_conns" yaml:"min_idle_conns"` // 最小空闲连接数
PoolSize int `json:"pool_size" yaml:"pool_size"` // 连接池大小,0 表示使用默认值(即 CPU 核心数 * 10)
MaxRetries int `json:"max_retries" yaml:"max_retries"` // 最大重试次数,-1 表示不重试,0 表示使用默认值(即 3 次)
DialTimeout int `json:"dial_timeout" yaml:"dial_timeout"` // 连接超时时间(秒),0 表示使用默认值(即 5 秒)
ReadTimeout int `json:"read_timeout" yaml:"read_timeout"` // 读取超时时间(秒),-1 表示不超时,0 表示使用默认值(即 3 秒)
WriteTimeout int `json:"write_timeout" yaml:"write_timeout"` // 写入超时时间(秒),-1 表示不超时,0 表示使用默认值(即 ReadTimeout)
PoolTimeout int `json:"pool_timeout" yaml:"pool_timeout"` // 连接池获取连接超时时间(秒),0 表示使用默认值(即 ReadTimeout + 1 秒)
IdleTimeout int `json:"idle_timeout" yaml:"idle_timeout"` // 空闲连接超时时间(秒),-1 表示禁用空闲连接超时检查,0 表示使用默认值(即 5 分钟)
UseTLS bool `json:"use_tls" yaml:"use_tls"` // 是否使用 TLS
// Deprecated: 应使用 MinIdleConns 代替
MaxIdle int `json:"max_idle" yaml:"max_idle"`
// Deprecated: 应使用 PoolSize 代替
MaxActive int `json:"max_active" yaml:"max_active"`
}
RedisOpts redis 连接属性
Click to show internal directories.
Click to hide internal directories.