Versions in this module Expand all Collapse all v1 v1.0.1 Aug 7, 2020 Changes in this version + func ClientIP4() ([]byte, error) + func FakeIP() []byte v1.0.0 Mar 17, 2020 Changes in this version + var CompressedFlag = 0x1 + var ErrMQEmpty = errors.New("MessageQueue is nil") + var ErrNumbers = errors.New("numbers < 0") + var ErrOffset = errors.New("offset < 0") + var ErrRequestTimeout = errors.New("request timeout") + var MultiTagsFlag = 0x1 << 1 + var TransactionCommitType = 0x2 << 2 + var TransactionNotType = 0 + var TransactionPreparedType = 0x1 << 2 + var TransactionRollbackType = 0x3 << 2 + func AbsInt(i int) int + func CheckError(action string, err error) + func ClassLoaderID() int32 + func ClearCompressedFlag(flag int) int + func FileReadAll(path string) ([]byte, error) + func GetAddressByBytes(data []byte) string + func GetTransactionValue(flag int) int + func HashString(s string) int + func IsArrayEmpty(i ...interface{}) bool + func LocalIP() string + func MakeFileIfNotExist(path string) error + func MessageClientID() string + func MinInt(a, b int) int + func Pid() int16 + func ResetTransactionValue(flag int, typeFlag int) int + func StrJoin(str, key string, value interface{}) string + func UnCompress(data []byte) []byte + func WriteToFile(path string, data []byte) error + type RingNodesBuffer struct + func NewRingNodesBuffer(cap uint64) *RingNodesBuffer + func (r *RingNodesBuffer) Destroy() + func (r *RingNodesBuffer) Read(timeout time.Duration) (data []byte, err error) + func (r *RingNodesBuffer) ReadBySize(data []byte, timeout time.Duration) (n int, err error) + func (r *RingNodesBuffer) Size() uint64 + func (r *RingNodesBuffer) Write(b []byte) error + func (rb *RingNodesBuffer) Cap() uint64 + type Set struct + func NewSet() Set + func (s *Set) Add(v UniqueItem) + func (s *Set) AddKV(k, v string) + func (s *Set) Contains(k string) (UniqueItem, bool) + func (s *Set) Len() int + func (s *Set) MarshalJSON() ([]byte, error) + func (s Set) UnmarshalJSON(data []byte) (err error) + type StringUnique string + func (str StringUnique) UniqueID() string + type UniqueItem interface + UniqueID func() string Incompatible versions in this module v2.0.0+incompatible Aug 7, 2020