tcp

Documentation

Index

• Variables
• func NewServer(addr string, opts ...Option) network.Server
• type Codec
  • func NewCodec(isBigEndian bool, magic uint16, maxBodyLen uint32) *Codec
  • func (slf *Codec) Decode(gn gnet.Conn) ([]byte, error)
  • func (slf *Codec) Encode(data []byte) ([]byte, error)
  • func (slf *Codec) Unpack(buf []byte) ([]byte, error)
• type Option
  • func WithMaxConnNum(maxConnNum int) Option
  • func WithMaxMsgLen(maxMsgLen uint32) Option
  • func WithRunMode(runMode network.RunMode) Option

Variables

var (
	ErrIncompletePacket = errors.New("incomplete packet")
	ErrTooLargePacket   = errors.New("too large packet")
)

Functions

func NewServer

func NewServer(addr string, opts ...Option) network.Server

Types

type Codec

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

func NewCodec

func NewCodec(isBigEndian bool, magic uint16, maxBodyLen uint32) *Codec

func (*Codec) Decode

func (slf *Codec) Decode(gn gnet.Conn) ([]byte, error)

func (*Codec) Encode

func (slf *Codec) Encode(data []byte) ([]byte, error)

func (*Codec) Unpack

func (slf *Codec) Unpack(buf []byte) ([]byte, error)

type Option

type Option func(*options)

func WithMaxConnNum

func WithMaxConnNum(maxConnNum int) Option

func WithMaxMsgLen

func WithMaxMsgLen(maxMsgLen uint32) Option

func WithRunMode

func WithRunMode(runMode network.RunMode) Option