redis

Documentation

Index

• type Client
  • func (ins *Client) CmdOnMaster() *redis.Client
  • func (ins *Client) CmdOnSlave() *redis.Client
• type Config
  • func DefaultConfig() *Config
  • func RawConfig(key string) *Config
  • func StdConfig(name string) *Config
  • func (config *Config) Build() (*Client, error)
  • func (config *Config) MustBuild() *Client
  • func (config *Config) MustSingleton() *Client
  • func (config *Config) Singleton() (*Client, error)

Types

type Client

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

func (*Client) CmdOnMaster

func (ins *Client) CmdOnMaster() *redis.Client

func (*Client) CmdOnSlave

func (ins *Client) CmdOnSlave() *redis.Client

type Config

type Config struct {
	// Master host:port addresses of Master node
	Master struct {
		Addr string `json:"addr" toml:"addr"`
	} `json:"master" toml:"master"`
	// Slaves A list of host:port addresses of Slave nodes.
	Slaves struct {
		Addr []string `json:"addr" toml:"addr"`
	} `json:"slaves" toml:"slaves"`

	/****** for github.com/go-redis/redis/v8 ******/
	// DB default 0,not recommend
	DB int `json:"db" toml:"db"`
	// PoolSize applies per Stub node and not for the whole Stub.
	PoolSize int `json:"poolSize" toml:"poolSize"`
	// Maximum number of retries before giving up.
	// Default is 3 retries; -1 (not 0) disables retries.
	MaxRetries int `json:"maxRetries" toml:"maxRetries"`
	// Minimum number of idle connections which is useful when establishing
	// new connection is slow.
	MinIdleConns int `json:"minIdleConns" toml:"minIdleConns"`
	// Dial timeout for establishing new connections.
	// Default is 5 seconds.
	DialTimeout time.Duration `json:"dialTimeout" toml:"dialTimeout"`
	// Timeout for socket reads. If reached, commands will fail
	// with a timeout instead of blocking. Use value 0 for no timeout and 0 for default.
	// Default is 3 seconds.
	ReadTimeout time.Duration `json:"readTimeout" toml:"readTimeout"`
	// Timeout for socket writes. If reached, commands will fail
	// with a timeout instead of blocking.
	// Default is ReadTimeout.
	WriteTimeout time.Duration `json:"writeTimeout" toml:"writeTimeout"`
	// Amount of time after which client closes idle connections.
	// Should be less than server's timeout.
	// Default is 5 minutes. -1 disables idle timeout check.
	IdleTimeout time.Duration `json:"idleTimeout" toml:"idleTimeout"`

	/****** for jupiter ******/
	ReadOnMaster bool `json:"readOnMaster" toml:"readOnMaster"`
	// nice option
	Debug bool `json:"debug" toml:"debug"`
	// a require will be recorded if cost bigger than this
	SlowLogThreshold time.Duration `json:"slowThreshold" toml:"slowThreshold"`
	// EnableMetric .. default true
	EnableMetricInterceptor bool `json:"enableMetric" toml:"enableMetric"`
	// EnableTrace .. default true
	EnableTraceInterceptor bool `json:"enableTrace" toml:"enableTrace"`
	// EnableAccessLog .. default false
	EnableAccessLogInterceptor bool `json:"enableAccessLog" toml:"enableAccessLog"`
	// EnableSentinel .. default true
	EnableSentinel bool `json:"enableSentinel" toml:"enableSentinel"`
	// OnDialError panic|error
	OnDialError string `json:"level"`
	// contains filtered or unexported fields
}

Config ...

func DefaultConfig

func DefaultConfig() *Config

DefaultConfig default config ...

func RawConfig

func RawConfig(key string) *Config

func StdConfig

func StdConfig(name string) *Config

StdConfig ...

func (*Config) Build

func (config *Config) Build() (*Client, error)

Build ..

func (*Config) MustBuild

func (config *Config) MustBuild() *Client

MustBuild panics when error found.

func (*Config) MustSingleton

func (config *Config) MustSingleton() *Client

MustSingleton panics when error found.

func (*Config) Singleton

func (config *Config) Singleton() (*Client, error)

Singleton returns a singleton client conn.