Documentation
¶
Index ¶
- func CaptureException()
- func ConsistentHashSelector(cons *consistent.Consistent, id string) selector.SelectOption
- func ErrCheck(err error, param ...interface{}) (*zerolog.Event, bool)
- func InitMachineID(machineID int16)
- func MachineID(id int64) int16
- func MachineIDHigh(id int64) int16
- func MachineIDLow(id int64) int16
- func NewPrometheusHandlerWrapper(opts ...server.Option) server.HandlerWrapper
- func NextID(tp int) (int64, error)
- func RelocatePath() error
- func SectionIDRandSelector(id int64) selector.SelectOption
- func SpecificIDSelector(id int64) selector.SelectOption
- type FakeRandom
- type Snowflakes
- type WaitGroupWrapper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CaptureException ¶
func CaptureException()
func ConsistentHashSelector ¶
func ConsistentHashSelector(cons *consistent.Consistent, id string) selector.SelectOption
select node by consistent hash
func InitMachineID ¶
func InitMachineID(machineID int16)
snow flakes machine_id: 10 bits machineID + 6 bits plugin_type
func MachineIDHigh ¶
func MachineIDLow ¶
func NewPrometheusHandlerWrapper ¶
func NewPrometheusHandlerWrapper(opts ...server.Option) server.HandlerWrapper
func SectionIDRandSelector ¶
func SectionIDRandSelector(id int64) selector.SelectOption
select node by section id: game_id / 10
func SpecificIDSelector ¶
func SpecificIDSelector(id int64) selector.SelectOption
select node by specific game_id
Types ¶
type FakeRandom ¶
type FakeRandom struct {
// contains filtered or unexported fields
}
func NewFakeRandom ¶
func NewFakeRandom(seed int) *FakeRandom
func (*FakeRandom) Rand ¶
func (f *FakeRandom) Rand() int
------------------------------------------------------------------------------- 生成一个SHORT伪随机数 -------------------------------------------------------------------------------
func (*FakeRandom) RandSection ¶
func (f *FakeRandom) RandSection(min, max int) int
func (*FakeRandom) Reset ¶
func (f *FakeRandom) Reset(seed int)
------------------------------------------------------------------------------- 重置种子 -------------------------------------------------------------------------------
type Snowflakes ¶
type Snowflakes struct {
// contains filtered or unexported fields
}
type WaitGroupWrapper ¶
func (*WaitGroupWrapper) Wrap ¶
func (w *WaitGroupWrapper) Wrap(cb func())
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.