wall

Documentation

Index

• Constants
• func Lz4Decode(data []byte) (b []byte, err error)
• func Lz4Encode(data []byte, level ...int) (mask uint16, b []byte)
• type Recv
  • func NewRecv(conf config.Configer) *Recv
  • func (m *Recv) Read(conn *net.TCPConn) (data []byte, err error)
• type Send
  • func NewSend(conf config.Configer) *Send
  • func (m *Send) Reconnect() (err error)
  • func (m *Send) Write(data []byte) (num int, err error)

Constants

const (
	MaskLz4  = 0x8000
	MaskNone = 0x7ff
	MaxSize  = 32*1024 - 1
)

MaskLz4 .

Functions

func Lz4Decode

func Lz4Decode(data []byte) (b []byte, err error)

Lz4Decode .

func Lz4Encode

func Lz4Encode(data []byte, level ...int) (mask uint16, b []byte)

Lz4Encode 最大32k

Types

type Recv

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

Recv .

func NewRecv

func NewRecv(conf config.Configer) *Recv

NewRecv .

func (*Recv) Read

func (m *Recv) Read(conn *net.TCPConn) (data []byte, err error)

Read .

type Send

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

Send 发送

func NewSend

func NewSend(conf config.Configer) *Send

NewSend .

func (*Send) Reconnect

func (m *Send) Reconnect() (err error)

Reconnect 重新连接

func (*Send) Write

func (m *Send) Write(data []byte) (num int, err error)

Write .