router

package
v0.0.0-...-535e59b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 4, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MaxSlotNum = models.MaxSlotNum

	AntsPoolSize = 96
)
View Source 
const (
	CloudTypeLocal  = "local"
	CloudTypeBackup = "backup"
)
View Source 
const (
	MgetCommandType = iota + 1
	MsetCommandType
	DelCommandType
	WatchCommandType
	UnwatchCommandType
	MultiCommandType
	PrepareCommandType
	ExecCommandType
	DiscardCommandType
)
View Source 
const (
	DefaultLocalCacheExpireTime = 120 * time.Second
)
View Source 
const MinBreakerOpenRequest uint32 = 10

Variables

This section is empty.

Functions

func GetPool 

func GetPool(conf models.RedisConnConf) *redis.Pool

func IsWriteCmd 

func IsWriteCmd(commandName string) bool

Types

type Breaker 

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

func NewCircuitBreaker 

func NewCircuitBreaker(opt *BreakerOption) *Breaker

func (*Breaker) AddBreakerByAddrs 

func (b *Breaker) AddBreakerByAddrs(addrs ...string) int

func (*Breaker) GetCircuitBreaker 

func (b *Breaker) GetCircuitBreaker(hystrixName string) *gobreaker.CircuitBreaker

func (*Breaker) RemoveCircuitBreakerByAddr 

func (b *Breaker) RemoveCircuitBreakerByAddr(addrs ...string) int

type BreakerOption 

type BreakerOption struct {
	BreakerStopTimeout    time.Duration
	BreakerOpenFailRate   float64
	BreakerRestoreRequest int
}

type GroupBreaker 

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

func NewGroupBreaker 

func NewGroupBreaker(conf *config.Config) *GroupBreaker

func (*GroupBreaker) AddCircuitBreaker 

func (gb *GroupBreaker) AddCircuitBreaker(gid int, addrs ...string)

func (*GroupBreaker) GetCircuitBreakerByGid 

func (gb *GroupBreaker) GetCircuitBreakerByGid(gid int) (*Breaker, error)

func (*GroupBreaker) RemoveCircuitBreaker 

func (gb *GroupBreaker) RemoveCircuitBreaker(gid int, addr string)

type HitStatus 

type HitStatus int
const (
	NotUseCacheStatus HitStatus = 0
	HitCacheStatus    HitStatus = 1
	NotHitCacheStatus HitStatus = 2
)

type InternalPool 

type InternalPool struct {
	HostPort string
	Pool     *redis.Pool
}

func (*InternalPool) GetConn 

func (p *InternalPool) GetConn() redis.Conn

func (*InternalPool) GetHostPort 

func (p *InternalPool) GetHostPort() string

func (*InternalPool) PoolClose 

func (p *InternalPool) PoolClose()

func (*InternalPool) Stats 

func (p *InternalPool) Stats() InternalPoolStat

type InternalPoolStat 

type InternalPoolStat struct {
	ActiveCount int
	IdleCount   int
}

type PclientConfig 

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

type ProxyClient 

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

func GetProxyClient 

func GetProxyClient() (*ProxyClient, error)

func NewProxyClient 

func NewProxyClient(cfg *config.Config) *ProxyClient

func (*ProxyClient) Append 

func (pc *ProxyClient) Append(s *resp.Session, key string, value string) (interface{}, error)

func (*ProxyClient) BitCount 

func (pc *ProxyClient) BitCount(s *resp.Session, args ...interface{}) (interface{}, error)

func (*ProxyClient) BitPos 

func (pc *ProxyClient) BitPos(s *resp.Session, key []byte, bit, start, end int) (interface{}, error)

func (*ProxyClient) CheckIsBlackKey 

func (pc *ProxyClient) CheckIsBlackKey(key string) bool

func (*ProxyClient) CheckIsWhiteKey 

func (pc *ProxyClient) CheckIsWhiteKey(key string) bool

func (*ProxyClient) Decr 

func (pc *ProxyClient) Decr(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) DecrBy 

func (pc *ProxyClient) DecrBy(s *resp.Session, key []byte, value int64) (interface{}, error)

func (*ProxyClient) Del 

func (pc *ProxyClient) Del(s *resp.Session, keys ...interface{}) (interface{}, error)

func (*ProxyClient) Discard 

func (pc *ProxyClient) Discard(s *resp.Session) error

func (*ProxyClient) DoProbeNode 

func (pc *ProxyClient) DoProbeNode()

func (*ProxyClient) EvalCommon 

func (pc *ProxyClient) EvalCommon(command string, s *resp.Session, args ...interface{}) (interface{}, error)

func (*ProxyClient) Exec 

func (pc *ProxyClient) Exec(s *resp.Session) (prepareOk bool, err error)

func (*ProxyClient) Exists 

func (pc *ProxyClient) Exists(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) Expire 

func (pc *ProxyClient) Expire(s *resp.Session, key string, duration int64) (interface{}, error)

func (*ProxyClient) ExpireAt 

func (pc *ProxyClient) ExpireAt(s *resp.Session, expireType string, key []byte, when int64) (interface{}, error)

func (*ProxyClient) FillPconfigs 

func (pc *ProxyClient) FillPconfigs(pconfigs []*models.Pconfig) error

func (*ProxyClient) FillSlot 

func (pc *ProxyClient) FillSlot(slot *models.Slot) error

func (*ProxyClient) FillSlots 

func (pc *ProxyClient) FillSlots(slots []*models.Slot) error

func (*ProxyClient) GeoAdd 

func (pc *ProxyClient) GeoAdd(s *resp.Session, args ...interface{}) (interface{}, error)

func (*ProxyClient) GeoDist 

func (pc *ProxyClient) GeoDist(s *resp.Session, args [][]byte) (interface{}, error)

func (*ProxyClient) GeoHash 

func (pc *ProxyClient) GeoHash(s *resp.Session, args [][]byte) (interface{}, error)

func (*ProxyClient) GeoPos 

func (pc *ProxyClient) GeoPos(s *resp.Session, args [][]byte) (interface{}, error)

func (*ProxyClient) GeoRadius 

func (pc *ProxyClient) GeoRadius(s *resp.Session, args ...interface{}) (interface{}, error)

func (*ProxyClient) GeoRadiusByMember 

func (pc *ProxyClient) GeoRadiusByMember(s *resp.Session, args ...interface{}) (interface{}, error)

func (*ProxyClient) Get 

func (pc *ProxyClient) Get(s *resp.Session, key string) (interface{}, error)

func (*ProxyClient) GetAllGroup 

func (pc *ProxyClient) GetAllGroup() map[int]int

func (*ProxyClient) GetBit 

func (pc *ProxyClient) GetBit(s *resp.Session, key []byte, offset int) (interface{}, error)

func (*ProxyClient) GetMasterClients 

func (pc *ProxyClient) GetMasterClients() (map[int]*resp.InternalServerConn, error)

func (*ProxyClient) GetRange 

func (pc *ProxyClient) GetRange(s *resp.Session, key []byte, start, end int) (interface{}, error)

func (*ProxyClient) GetSet 

func (pc *ProxyClient) GetSet(s *resp.Session, key string, value string) (interface{}, error)

func (*ProxyClient) HClear 

func (pc *ProxyClient) HClear(s *resp.Session, keys ...[]byte) (interface{}, error)

func (*ProxyClient) HDel 

func (pc *ProxyClient) HDel(s *resp.Session, key []byte, fields ...[]byte) (interface{}, error)

func (*ProxyClient) HExists 

func (pc *ProxyClient) HExists(s *resp.Session, key []byte, field []byte) (interface{}, error)

func (*ProxyClient) HExpire 

func (pc *ProxyClient) HExpire(s *resp.Session, key []byte, duration int64) (interface{}, error)

func (*ProxyClient) HExpireAt 

func (pc *ProxyClient) HExpireAt(s *resp.Session, key []byte, when int64) (interface{}, error)

func (*ProxyClient) HGet 

func (pc *ProxyClient) HGet(s *resp.Session, key []byte, field []byte) (interface{}, error)

func (*ProxyClient) HGetAll 

func (pc *ProxyClient) HGetAll(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) HIncrBy 

func (pc *ProxyClient) HIncrBy(s *resp.Session, key []byte, field []byte, value int64) (interface{}, error)

func (*ProxyClient) HKeyExists 

func (pc *ProxyClient) HKeyExists(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) HKeys 

func (pc *ProxyClient) HKeys(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) HLen 

func (pc *ProxyClient) HLen(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) HMGet 

func (pc *ProxyClient) HMGet(s *resp.Session, key []byte, fields ...[]byte) (interface{}, error)

func (*ProxyClient) HMSet 

func (pc *ProxyClient) HMSet(s *resp.Session, key string, fvmap map[string]interface{}) (interface{}, error)

func (*ProxyClient) HPersist 

func (pc *ProxyClient) HPersist(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) HScan 

func (pc *ProxyClient) HScan(s *resp.Session, key []byte, cursor []byte, pattern string, count int) ([]byte, [][]byte, error)

func (*ProxyClient) HSet 

func (pc *ProxyClient) HSet(s *resp.Session, key string, field string, val string) (interface{}, error)

func (*ProxyClient) HSetWithRes 

func (pc *ProxyClient) HSetWithRes(s *resp.Session, key []byte, field []byte, val []byte) (interface{}, error)

func (*ProxyClient) HTtl 

func (pc *ProxyClient) HTtl(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) HVals 

func (pc *ProxyClient) HVals(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) Incr 

func (pc *ProxyClient) Incr(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) IncrBy 

func (pc *ProxyClient) IncrBy(s *resp.Session, key []byte, value int64) (interface{}, error)

func (*ProxyClient) IncrByFloat 

func (pc *ProxyClient) IncrByFloat(s *resp.Session, key []byte, value interface{}) (interface{}, error)

func (*ProxyClient) KDel 

func (pc *ProxyClient) KDel(s *resp.Session, keys ...string) (interface{}, error)

func (*ProxyClient) KExists 

func (pc *ProxyClient) KExists(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) KExpire 

func (pc *ProxyClient) KExpire(s *resp.Session, key string, duration int64) (interface{}, error)

func (*ProxyClient) KExpireAt 

func (pc *ProxyClient) KExpireAt(s *resp.Session, key []byte, when int64) (interface{}, error)

func (*ProxyClient) KPersist 

func (pc *ProxyClient) KPersist(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) KTtl 

func (pc *ProxyClient) KTtl(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) LClear 

func (pc *ProxyClient) LClear(s *resp.Session, keys ...[]byte) (interface{}, error)

func (*ProxyClient) LExpire 

func (pc *ProxyClient) LExpire(s *resp.Session, key []byte, duration int64) (interface{}, error)

func (*ProxyClient) LExpireAt 

func (pc *ProxyClient) LExpireAt(s *resp.Session, key []byte, when int64) (interface{}, error)

func (*ProxyClient) LIndex 

func (pc *ProxyClient) LIndex(s *resp.Session, key []byte, index int) (interface{}, error)

func (*ProxyClient) LInsert 

func (pc *ProxyClient) LInsert(s *resp.Session, key []byte, before string, pivot string, value string) (interface{}, error)

func (*ProxyClient) LKeyExists 

func (pc *ProxyClient) LKeyExists(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) LLen 

func (pc *ProxyClient) LLen(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) LPersist 

func (pc *ProxyClient) LPersist(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) LPop 

func (pc *ProxyClient) LPop(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) LPush 

func (pc *ProxyClient) LPush(s *resp.Session, key []byte, members ...[]byte) (interface{}, error)

func (*ProxyClient) LPushX 

func (pc *ProxyClient) LPushX(s *resp.Session, key []byte, members ...[]byte) (interface{}, error)

func (*ProxyClient) LRange 

func (pc *ProxyClient) LRange(s *resp.Session, key []byte, start int, stop int) (interface{}, error)

func (*ProxyClient) LRem 

func (pc *ProxyClient) LRem(s *resp.Session, key []byte, count int, value interface{}) (interface{}, error)

func (*ProxyClient) LSet 

func (pc *ProxyClient) LSet(s *resp.Session, key []byte, index int, value interface{}) (interface{}, error)

func (*ProxyClient) LTrim 

func (pc *ProxyClient) LTrim(s *resp.Session, key []byte, start int, stop int) (interface{}, error)

func (*ProxyClient) LTrimBack 

func (pc *ProxyClient) LTrimBack(s *resp.Session, key []byte, size int64) (interface{}, error)

func (*ProxyClient) LTrimFront 

func (pc *ProxyClient) LTrimFront(s *resp.Session, key []byte, size int64) (interface{}, error)

func (*ProxyClient) LTtl 

func (pc *ProxyClient) LTtl(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) MGet 

func (pc *ProxyClient) MGet(s *resp.Session, keys [][]byte) (interface{}, error)

func (*ProxyClient) MSet 

func (pc *ProxyClient) MSet(s *resp.Session, values ...string) (interface{}, error)

func (*ProxyClient) Multi 

func (pc *ProxyClient) Multi(s *resp.Session) error

func (*ProxyClient) PExpire 

func (pc *ProxyClient) PExpire(s *resp.Session, key string, duration int64) (interface{}, error)

func (*ProxyClient) Pconfigs 

func (pc *ProxyClient) Pconfigs() []*models.Pconfig

func (*ProxyClient) Persist 

func (pc *ProxyClient) Persist(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) RPop 

func (pc *ProxyClient) RPop(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) RPush 

func (pc *ProxyClient) RPush(s *resp.Session, key []byte, members ...[]byte) (interface{}, error)

func (*ProxyClient) RPushX 

func (pc *ProxyClient) RPushX(s *resp.Session, key []byte, members ...[]byte) (interface{}, error)

func (*ProxyClient) SAdd 

func (pc *ProxyClient) SAdd(s *resp.Session, key []byte, members ...[]byte) (interface{}, error)

func (*ProxyClient) SCard 

func (pc *ProxyClient) SCard(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) SClear 

func (pc *ProxyClient) SClear(s *resp.Session, keys ...[]byte) (interface{}, error)

func (*ProxyClient) SExpire 

func (pc *ProxyClient) SExpire(s *resp.Session, key []byte, duration int64) (interface{}, error)

func (*ProxyClient) SExpireAt 

func (pc *ProxyClient) SExpireAt(s *resp.Session, key []byte, when int64) (interface{}, error)

func (*ProxyClient) SIsMember 

func (pc *ProxyClient) SIsMember(s *resp.Session, key []byte, member []byte) (interface{}, error)

func (*ProxyClient) SKeyExists 

func (pc *ProxyClient) SKeyExists(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) SMembers 

func (pc *ProxyClient) SMembers(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) SPersist 

func (pc *ProxyClient) SPersist(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) SPop 

func (pc *ProxyClient) SPop(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) SPopByCount 

func (pc *ProxyClient) SPopByCount(s *resp.Session, key []byte, count int64) (interface{}, error)

func (*ProxyClient) SRandMemberCommandWithCount 

func (pc *ProxyClient) SRandMemberCommandWithCount(s *resp.Session, key []byte, count int) (interface{}, error)

func (*ProxyClient) SRandMemberCommandWithoutCount 

func (pc *ProxyClient) SRandMemberCommandWithoutCount(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) SRem 

func (pc *ProxyClient) SRem(s *resp.Session, key []byte, members ...[]byte) (interface{}, error)

func (*ProxyClient) SScan 

func (pc *ProxyClient) SScan(s *resp.Session, key string, cursor []byte, pattern string, count int) ([]byte, [][]byte, error)

func (*ProxyClient) STtl 

func (pc *ProxyClient) STtl(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) ScriptExists 

func (pc *ProxyClient) ScriptExists(command string, s *resp.Session, args ...interface{}) (interface{}, error)

func (*ProxyClient) ScriptFlush 

func (pc *ProxyClient) ScriptFlush(s *resp.Session) (interface{}, error)

func (*ProxyClient) ScriptLen 

func (pc *ProxyClient) ScriptLen(s *resp.Session) (interface{}, error)

func (*ProxyClient) ScriptLoad 

func (pc *ProxyClient) ScriptLoad(s *resp.Session, script string) (interface{}, error)

func (*ProxyClient) Set 

func (pc *ProxyClient) Set(s *resp.Session, key string, value string, exType resp.ExpireType, expire int64) (interface{}, error)

func (*ProxyClient) SetBit 

func (pc *ProxyClient) SetBit(s *resp.Session, key []byte, offset, value int) (interface{}, error)

func (*ProxyClient) SetNx 

func (pc *ProxyClient) SetNx(s *resp.Session, key []byte, value []byte) (interface{}, error)

func (*ProxyClient) SetNxByEX 

func (pc *ProxyClient) SetNxByEX(s *resp.Session, key []byte, value []byte, expire uint64) (interface{}, error)

func (*ProxyClient) SetNxByPX 

func (pc *ProxyClient) SetNxByPX(s *resp.Session, key []byte, value []byte, expire uint64) (interface{}, error)

func (*ProxyClient) SetRange 

func (pc *ProxyClient) SetRange(s *resp.Session, key string, offset int, value string) (interface{}, error)

func (*ProxyClient) Slots 

func (pc *ProxyClient) Slots() []*models.Slot

func (*ProxyClient) StrLen 

func (pc *ProxyClient) StrLen(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) TTL 

func (pc *ProxyClient) TTL(ttlType string, s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) Type 

func (pc *ProxyClient) Type(key []byte, s *resp.Session) (interface{}, error)

func (*ProxyClient) Unwatch 

func (pc *ProxyClient) Unwatch(s *resp.Session) error

func (*ProxyClient) Watch 

func (pc *ProxyClient) Watch(s *resp.Session, args [][]byte) error

func (*ProxyClient) ZAdd 

func (pc *ProxyClient) ZAdd(s *resp.Session, key string, maps map[string]float64) (interface{}, error)

func (*ProxyClient) ZCard 

func (pc *ProxyClient) ZCard(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) ZClear 

func (pc *ProxyClient) ZClear(s *resp.Session, keys ...[]byte) (interface{}, error)

func (*ProxyClient) ZCount 

func (pc *ProxyClient) ZCount(s *resp.Session, key, min, max string) (interface{}, error)

func (*ProxyClient) ZExpire 

func (pc *ProxyClient) ZExpire(s *resp.Session, key []byte, duration int64) (interface{}, error)

func (*ProxyClient) ZExpireAt 

func (pc *ProxyClient) ZExpireAt(s *resp.Session, key []byte, when int64) (interface{}, error)

func (*ProxyClient) ZIncrBy 

func (pc *ProxyClient) ZIncrBy(s *resp.Session, key []byte, delta float64, member []byte) (interface{}, error)

func (*ProxyClient) ZKeyExists 

func (pc *ProxyClient) ZKeyExists(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) ZLexCount 

func (pc *ProxyClient) ZLexCount(s *resp.Session, key, min, max string) (interface{}, error)

func (*ProxyClient) ZPersist 

func (pc *ProxyClient) ZPersist(s *resp.Session, key []byte) (interface{}, error)

func (*ProxyClient) ZRange 

func (pc *ProxyClient) ZRange(s *resp.Session, key string, start int, stop int, withscores bool) (interface{}, error)

func (*ProxyClient) ZRangeByLex 

func (pc *ProxyClient) ZRangeByLex(s *resp.Session, args ...interface{}) (interface{}, error)

func (*ProxyClient) ZRangeByScore 

func (pc *ProxyClient) ZRangeByScore(s *resp.Session, key, min, max string, withscores, limit bool, offset int, count int) (interface{}, error)

func (*ProxyClient) ZRank 

func (pc *ProxyClient) ZRank(s *resp.Session, key []byte, member []byte) (interface{}, error)

func (*ProxyClient) ZRem 

func (pc *ProxyClient) ZRem(s *resp.Session, key []byte, members ...[]byte) (interface{}, error)

func (*ProxyClient) ZRemRangeByLex 

func (pc *ProxyClient) ZRemRangeByLex(s *resp.Session, key, min, max string) (interface{}, error)

func (*ProxyClient) ZRemRangeByRank 

func (pc *ProxyClient) ZRemRangeByRank(s *resp.Session, key string, start int, stop int) (interface{}, error)

func (*ProxyClient) ZRemRangeByScore 

func (pc *ProxyClient) ZRemRangeByScore(s *resp.Session, key, min, max string) (interface{}, error)

func (*ProxyClient) ZRevRange 

func (pc *ProxyClient) ZRevRange(s *resp.Session, key string, start int, stop int, withscores bool) (interface{}, error)

func (*ProxyClient) ZRevRangeByScore 

func (pc *ProxyClient) ZRevRangeByScore(s *resp.Session, key, max, min string, withscores, limit bool, offset int, count int) (interface{}, error)

func (*ProxyClient) ZRevRank 

func (pc *ProxyClient) ZRevRank(s *resp.Session, key []byte, member []byte) (interface{}, error)

func (*ProxyClient) ZScan 

func (pc *ProxyClient) ZScan(s *resp.Session, key string, cursor []byte, pattern string, count int) ([]byte, [][]byte, error)

func (*ProxyClient) ZScore 

func (pc *ProxyClient) ZScore(s *resp.Session, key []byte, member []byte) (interface{}, error)

func (*ProxyClient) ZTtl 

func (pc *ProxyClient) ZTtl(s *resp.Session, key []byte) (interface{}, error)

type Router 

type Router struct {
	GroupBreaker *GroupBreaker
	// contains filtered or unexported fields
}

func NewRouter 

func NewRouter(config *config.Config) *Router

func (*Router) Close 

func (r *Router) Close()

func (*Router) FillSlot 

func (r *Router) FillSlot(m *models.Slot) error

func (*Router) FlushGlobalStat 

func (r *Router) FlushGlobalStat()

func (*Router) GetAddrPool 

func (r *Router) GetAddrPool(addr string) (*InternalPool, bool)

func (*Router) GetAnotherConnByCircuit 

func (r *Router) GetAnotherConnByCircuit(slotId int, command string, prevIndex uint64, prevCloud string) (*InternalPool, uint64, error)

func (*Router) GetAntsPool 

func (r *Router) GetAntsPool(addr string) (*ants.PoolWithFunc, bool)

func (*Router) GetConn 

func (r *Router) GetConn(
	slotId int, command string,
) (interPool *InternalPool, needCircuit bool, curindex uint64, cloudType string, err error)

func (*Router) GetGroupId 

func (r *Router) GetGroupId(slotId int) (int, error)

func (*Router) GetMasterConn 

func (r *Router) GetMasterConn(slotId int) (interPool *InternalPool, err error)

func (*Router) GetSlot 

func (r *Router) GetSlot(id int) *models.Slot

func (*Router) GetSlots 

func (r *Router) GetSlots() []*models.Slot

func (*Router) Hash 

func (r *Router) Hash(key interface{}) int

func (*Router) HashForLua 

func (r *Router) HashForLua(key string) int

func (*Router) PoolStats 

func (r *Router) PoolStats() InternalPoolStat

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.