utils

Documentation

Index

• Constants
• func CreatePidFile(name string) error
• func GetCoordLock(coordConn zkhelper.Conn, productName string) zkhelper.ZLocker
• func GetExecutorPath() string
• func GetRedisConfig(addr string, configName string, auth string) (string, error)
• func GetRedisInfo(addr string, section string, auth string) (string, error)
• func GetRedisStat(addr string, auth string) (map[string]string, error)
• func GetRole(addr string, auth string) (string, error)
• func InitConfig() (*cfg.Cfg, error)
• func InitConfigFromFile(filename string) (*cfg.Cfg, error)
• func Ping(addr string, auth string) error
• func SlaveNoOne(addr string, auth string) error
• func SlaveOf(slave string, master string, auth string) error
• func SlotsInfo(addr string, fromSlot int, toSlot int, auth string) (map[int]int, error)
• type Strings
  • func (s1 Strings) Eq(s2 []string) bool

Constants

const (
	RedisConnConnectTimeout = 1 * time.Second
	RedisConnReadTimeout    = 1 * time.Second
	RedisConnWriteTimeout   = 1 * time.Second
)

Functions

func CreatePidFile

func CreatePidFile(name string) error

func GetCoordLock

func GetCoordLock(coordConn zkhelper.Conn, productName string) zkhelper.ZLocker

func GetExecutorPath

func GetExecutorPath() string

func GetRedisConfig

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

func GetRedisInfo

func GetRedisInfo(addr string, section string, auth string) (string, error)

func GetRedisStat

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

func GetRole

func GetRole(addr string, auth string) (string, error)

func InitConfig

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

func InitConfigFromFile

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

func Ping

func Ping(addr string, auth string) error

func SlaveNoOne

func SlaveNoOne(addr string, auth string) error

func SlaveOf

func SlaveOf(slave string, master string, auth string) error

func SlotsInfo

func SlotsInfo(addr string, fromSlot int, toSlot int, auth string) (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