Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var NewSession = func(opt config.Redis) (ISession, error) { rdsOpt := &redis.Options{ Addr: fmt.Sprintf("%s:%s", opt.RedisHost, opt.RedisPort), DB: 0, } if opt.RedisClientName != "" { rdsOpt.ClientName = opt.RedisClientName } if opt.RedisUsername != "" { rdsOpt.Username = opt.RedisUsername } if opt.RedisPassword != "" { rdsOpt.Password = opt.RedisPassword } if opt.RedisPoolSize > 0 { rdsOpt.PoolSize = opt.RedisPoolSize } return redis.NewClient(rdsOpt), nil }
NewSession method
Functions ¶
This section is empty.
Types ¶
type ISession ¶
type ISession interface {
redis.Cmdable
WithTimeout(timeout time.Duration) *redis.Client
Conn() *redis.Conn
Do(ctx context.Context, args ...interface{}) *redis.Cmd
Process(ctx context.Context, cmd redis.Cmder) error
Options() *redis.Options
PoolStats() *redis.PoolStats
Pipelined(ctx context.Context, fn func(redis.Pipeliner) error) ([]redis.Cmder, error)
Pipeline() redis.Pipeliner
TxPipelined(ctx context.Context, fn func(redis.Pipeliner) error) ([]redis.Cmder, error)
TxPipeline() redis.Pipeliner
Subscribe(ctx context.Context, channels ...string) *redis.PubSub
PSubscribe(ctx context.Context, channels ...string) *redis.PubSub
SSubscribe(ctx context.Context, channels ...string) *redis.PubSub
String() string
Close() error
AddHook(hook redis.Hook)
}
ISession interface
Source Files
Click to show internal directories.
Click to hide internal directories.