ws

Documentation

Index

• Constants
• Variables
• func NewAcceptor() lib.Peer
• func NewConnector() lib.Peer
• func NewSyncConnector() lib.Peer
• type MsgHooker
  • func (self MsgHooker) OnInboundEvent(inputEvent lib.Event) (outputEvent lib.Event)
  • func (self MsgHooker) OnOutboundEvent(inputEvent lib.Event) (outputEvent lib.Event)
• type PacketMessagePeeker
• type WSMessageTransmitter
  • func (WSMessageTransmitter) OnRecvMessage(ses lib.Session) (msg interface{}, err error)
  • func (WSMessageTransmitter) OnSendMessage(ses lib.Session, msg interface{}) error

Constants

const (
	MsgLenSize  = 2 // uint16
	MsgIdSize   = 2 // uint16
	MsgHeadSize = 4 // 2 + 2
)

Variables

var (
	TotalRecv = 0
	TotalSend = 0
)

Functions

func NewAcceptor

func NewAcceptor() lib.Peer

func NewConnector

func NewConnector() lib.Peer

func NewSyncConnector

func NewSyncConnector() lib.Peer

Types

type MsgHooker

type MsgHooker struct {
}

带有RPC和relay功能

func (MsgHooker) OnInboundEvent

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

func (MsgHooker) OnOutboundEvent

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

type PacketMessagePeeker

type PacketMessagePeeker interface {
	Message() interface{}
}

萃取消息中的消息

type WSMessageTransmitter

type WSMessageTransmitter struct {
}

func (WSMessageTransmitter) OnRecvMessage

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

func (WSMessageTransmitter) OnSendMessage

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