Versions in this module Expand all Collapse all v1 v1.0.0 Nov 13, 2018 Changes in this version + var ErrInvalidPortRange = errors.New("invalid port range") + var ErrMaxPacket = errors.New("packet over size") + var ErrMinPacket = errors.New("packet short size") + var ErrShortMsgID = errors.New("short msgid") + func CompressBytes(data []byte) ([]byte, error) + func DecompressBytes(data []byte) ([]byte, error) + func DetectPort(addr string, fn func(string) (interface{}, error)) (interface{}, error) + func FileExists(name string) bool + func FileSize(name string) int64 + func GetLocalIP() string + func GetPrivateIPv4() ([]*net.IPAddr, error) + func GetPublicIPv6() ([]*net.IPAddr, error) + func GetRemoteAddrss(ses cellnet.Session) (string, bool) + func IsEOFOrNetReadError(err error) bool + func JoinAddress(host string, port int) string + func ReadFileLines(filename string, callback func(line string) bool) error + func RecvLTVPacket(reader io.Reader, maxPacketSize int) (msg interface{}, err error) + func SendLTVPacket(writer io.Writer, ctx cellnet.ContextSet, data interface{}) error + func SpliteAddress(addr string) (host string, port int, err error) + func StringHash(s string) (hash uint16) + func WriteFull(writer io.Writer, buf []byte) error + type Queue struct + func NewQueue(size int) *Queue + func (self *Queue) Count() int + func (self *Queue) Dequeue() (ret interface{}) + func (self *Queue) Enqueue(data interface{}) + func (self *Queue) Peek() interface{}