Documentation
¶
Index ¶
- Variables
- func AbsInt(i int) int
- func CheckError(action string, err error)
- func ClientIP4() ([]byte, error)
- func FakeIP() []byte
- func FileReadAll(path string) ([]byte, error)
- func GetAddressByBytes(data []byte) string
- func HashString(s string) int
- func MinInt(a, b int) int
- func StrJoin(str, key string, value interface{}) string
- func UnCompress(data []byte) []byte
- func WriteToFile(path string, data []byte) error
- type RingNodesBuffer
- func (rb *RingNodesBuffer) Cap() uint64
- 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
- type Set
- type StringUnique
- type UniqueItem
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrRequestTimeout for request timeout error ErrRequestTimeout = errors.New("request timeout") ErrMQEmpty = errors.New("MessageQueue is nil") ErrOffset = errors.New("offset < 0") ErrNumbers = errors.New("numbers < 0") )
View Source
var (
LocalIP string
)
Functions ¶
func CheckError ¶
func FileReadAll ¶
func GetAddressByBytes ¶
func UnCompress ¶
func WriteToFile ¶
Types ¶
type RingNodesBuffer ¶
type RingNodesBuffer struct {
// contains filtered or unexported fields
}
1.需要能够动态扩容 2.缩容看情况 3.read的时候需要block 4.线程安全
func NewRingNodesBuffer ¶
func NewRingNodesBuffer(cap uint64) *RingNodesBuffer
func (*RingNodesBuffer) Cap ¶
func (rb *RingNodesBuffer) Cap() uint64
Cap returns the capacity of this ring buffer.
func (*RingNodesBuffer) Destroy ¶
func (r *RingNodesBuffer) Destroy()
func (*RingNodesBuffer) Read ¶
func (r *RingNodesBuffer) Read(timeout time.Duration) (data []byte, err error)
直接返回数据
func (*RingNodesBuffer) ReadBySize ¶
知道大小，传进去解析
func (*RingNodesBuffer) Size ¶
func (r *RingNodesBuffer) Size() uint64
func (*RingNodesBuffer) Write ¶
func (r *RingNodesBuffer) Write(b []byte) error
type Set ¶
type Set struct {
// contains filtered or unexported fields
}
func (*Set) Add ¶
func (s *Set) Add(v UniqueItem)
func (*Set) MarshalJSON ¶
func (Set) UnmarshalJSON ¶
type StringUnique ¶
type StringUnique string
func (StringUnique) UniqueID ¶
func (str StringUnique) UniqueID() string
type UniqueItem ¶
type UniqueItem interface {
UniqueID() string
}
Source Files
Click to show internal directories.
Click to hide internal directories.