frontend

Documentation

Index

• Constants
• Variables
• func ProcFrontendPacket(msgId int32, msgData []byte, ses lib.Session) (msg interface{}, err error)
• func RecvLTVPacketData(reader io.Reader, maxPacketSize int) (msgId int32, msgData []byte, err error)
• type DirectTCPTransmitter
  • func (DirectTCPTransmitter) OnRecvMessage(ses lib.Session) (msg interface{}, err error)
  • func (DirectTCPTransmitter) OnSendMessage(ses lib.Session, msg interface{}) (err error)
• type DirectWSMessageTransmitter
  • func (DirectWSMessageTransmitter) OnRecvMessage(ses lib.Session) (msg interface{}, err error)
  • func (DirectWSMessageTransmitter) OnSendMessage(ses lib.Session, msg interface{}) error
• type FrontendEventHooker
  • func (FrontendEventHooker) OnInboundEvent(inputEvent lib.Event) (outputEvent lib.Event)
  • func (FrontendEventHooker) OnOutboundEvent(inputEvent lib.Event) (outputEvent lib.Event)

Constants

const (
	MsgIdSize = 2 // uint16
)

Variables

var (
	ErrAlreadyBind           = errors.New("already bind user")
	ErrBackendSDNotFound     = errors.New("backend sd not found")
	ErrBackendServerNotFound = errors.New("backend svc not found")
)

var (
	PingAckMsgId   = codec.MessageMetaByFullName("msgProto.PingAck").Id
	VerifyReqMsgId = codec.MessageMetaByFullName("msgProto.VerifyReq").Id
)

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

Functions

func ProcFrontendPacket

func ProcFrontendPacket(msgId int32, msgData []byte, ses lib.Session) (msg interface{}, err error)

func RecvLTVPacketData

func RecvLTVPacketData(reader io.Reader, maxPacketSize int) (msgId int32, msgData []byte, err error)

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

Types

type DirectTCPTransmitter

type DirectTCPTransmitter struct {
}

func (DirectTCPTransmitter) OnRecvMessage

func (DirectTCPTransmitter) OnRecvMessage(ses lib.Session) (msg interface{}, err error)

来自客户端的消息

func (DirectTCPTransmitter) OnSendMessage

func (DirectTCPTransmitter) OnSendMessage(ses lib.Session, msg interface{}) (err error)

网关发往客户端的消息

type DirectWSMessageTransmitter

type DirectWSMessageTransmitter struct {
}

func (DirectWSMessageTransmitter) OnRecvMessage

func (DirectWSMessageTransmitter) OnRecvMessage(ses lib.Session) (msg interface{}, err error)

func (DirectWSMessageTransmitter) OnSendMessage

func (DirectWSMessageTransmitter) OnSendMessage(ses lib.Session, msg interface{}) error

type FrontendEventHooker

type FrontendEventHooker struct {
}

func (FrontendEventHooker) OnInboundEvent

func (FrontendEventHooker) OnInboundEvent(inputEvent lib.Event) (outputEvent lib.Event)

网关内部抛出的事件

func (FrontendEventHooker) OnOutboundEvent

func (FrontendEventHooker) OnOutboundEvent(inputEvent lib.Event) (outputEvent lib.Event)

发送到客户端的消息