redis_client

type Client interface {
	Setex(key string, value []byte, expire int) error
	Get(key string) (interface{}, error)
	Expire(key string, expire int) error
	Incr(key string) (int64, error)
	IncrAndExpire(key string, expire int) (int64, error)
	Decr(key string) (int64, error)
	PIncr([]string) ([]int64, error)
	GetInt64(key string) (int64, error)
	IncrBy(key string, delta int64) (int64, error)
}

type Options struct {
	// ServiceConf: string, bns name or a batch of bns name with weight of redis server
	ServiceConf string

	// MaxIdle: int, max idle connections in connection pool
	MaxIdle int
	// MaxActive: int, max active connections in connection pool
	MaxActive int
	// wait: bool, if wait is true and pool at the maxActive limit,
	// command waits for a connection return to the pool
	Wait bool
	// ConnTimeoutMs: int, connect redis server timeout, in ms
	ConnTimeoutMs int
	// ReadTimeoutMs: int, read redis server timeout, in ms
	ReadTimeoutMs int
	// writeTimeoutMs: int, write redis server timeout, in ms
	WriteTimeoutMs int
	Password       string
	// contains filtered or unexported fields
}

type RedisClient struct {
	ConnectTimeout time.Duration // connect timeout (ms)
	ReadTimeout    time.Duration // read timeout (ms)
	WriteTimeout   time.Duration // write timeout (ms)

	Password string // password, ignore if no password

	MaxIdle   int  // max idle conenctions in pool
	MaxActive int  // max active connections in pool
	Wait      bool // if pool meet MaxActive limit, and Wait is true, wait for a connection return to pool
	// contains filtered or unexported fields
}

type RedisClusterConf struct {
	// contains filtered or unexported fields
}