utils

Documentation

Index

• func GetExecutorPath() string
• func GetRedisConfig(addr string, configName string) (string, error)
• func GetRedisStat(addr string) (map[string]string, error)
• func GetZkLock(zkConn zkhelper.Conn, productName string) zkhelper.ZLocker
• func InitConfig() (*cfg.Cfg, error)
• func InitConfigFromFile(filename string) (*cfg.Cfg, error)
• func SlaveNoOne(addr string) error
• func SlotsInfo(addr string, fromSlot, toSlot int) (map[int]int, error)
• type Strings
  • func (s1 Strings) Eq(s2 []string) bool
• type Token
• type TokenLimiter
  • func NewTokenLimiter(count int) *TokenLimiter
  • func (tl *TokenLimiter) Get() *Token
  • func (tl *TokenLimiter) Put(tk *Token)

Functions

func GetExecutorPath

func GetExecutorPath() string

func GetRedisConfig

func GetRedisConfig(addr string, configName string) (string, error)

func GetRedisStat

func GetRedisStat(addr string) (map[string]string, error)

func GetZkLock

func GetZkLock(zkConn zkhelper.Conn, productName string) zkhelper.ZLocker

func InitConfig

func InitConfig() (*cfg.Cfg, error)

func InitConfigFromFile

func InitConfigFromFile(filename string) (*cfg.Cfg, error)

func SlaveNoOne

func SlaveNoOne(addr string) error

func SlotsInfo

func SlotsInfo(addr string, fromSlot, toSlot int) (map[int]int, error)

get redis's slot size

Types

type Strings

type Strings []string

func (Strings) Eq

func (s1 Strings) Eq(s2 []string) bool

type Token

type Token struct {
}

type TokenLimiter

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

func NewTokenLimiter

func NewTokenLimiter(count int) *TokenLimiter

func (*TokenLimiter) Get

func (tl *TokenLimiter) Get() *Token

func (*TokenLimiter) Put

func (tl *TokenLimiter) Put(tk *Token)