tcp

Documentation

Index

• Variables
• func InitProc(order binary.ByteOrder, bodySize int)
• func RecvLVPacket(reader io.Reader, maxPacketSize int, order binary.ByteOrder, bodySize int) (msg interface{}, err error)
• func SendLVPacket(writer io.Writer, _ cellnet.ContextSet, data interface{}, ...) error
• func WriteFull(writer io.Writer, buf []byte) error
• type MsgHooker
  • func (self MsgHooker) OnInboundEvent(inputEvent cellnet.Event) (outputEvent cellnet.Event)
  • func (self MsgHooker) OnOutboundEvent(inputEvent cellnet.Event) (outputEvent cellnet.Event)
• type TCPMessageTransmitter
  • func (t *TCPMessageTransmitter) OnRecvMessage(ses cellnet.Session) (msg interface{}, err error)
  • func (t *TCPMessageTransmitter) OnSendMessage(ses cellnet.Session, msg interface{}) (err error)

Variables

var (
	ErrMaxPacket = errors.New("packet over size")
	ErrMinPacket = errors.New("packet short size")
)

Functions

func InitProc

func InitProc(order binary.ByteOrder, bodySize int)

InitProc 使用"tcp.lv"前需自行在init()中调用这个函数

func RecvLVPacket

func RecvLVPacket(reader io.Reader, maxPacketSize int, order binary.ByteOrder, bodySize int) (msg interface{}, err error)

RecvLVPacket 接收Length-Value格式的封包流程

func SendLVPacket

func SendLVPacket(writer io.Writer, _ cellnet.ContextSet, data interface{}, order binary.ByteOrder, bodySize int) error

SendLVPacket 发送Length-Value格式的封包流程

func WriteFull

func WriteFull(writer io.Writer, buf []byte) error

WriteFull 完整发送所有封包

Types

type MsgHooker

type MsgHooker struct {
}

带有RPC和relay功能

func (MsgHooker) OnInboundEvent

func (self MsgHooker) OnInboundEvent(inputEvent cellnet.Event) (outputEvent cellnet.Event)

func (MsgHooker) OnOutboundEvent

func (self MsgHooker) OnOutboundEvent(inputEvent cellnet.Event) (outputEvent cellnet.Event)

type TCPMessageTransmitter

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

func (*TCPMessageTransmitter) OnRecvMessage

func (t *TCPMessageTransmitter) OnRecvMessage(ses cellnet.Session) (msg interface{}, err error)

func (*TCPMessageTransmitter) OnSendMessage

func (t *TCPMessageTransmitter) OnSendMessage(ses cellnet.Session, msg interface{}) (err error)