relay

package

v0.0.1 Latest Latest Go to latest Published: Mar 25, 2020 License: MIT Imports: 8 Imported by: 1

Details

This section is empty.

View Source

var (
	ErrInvalidPeerSession = errors.New("relay: Require cellnet.Session")
)

func Relay(sesDetector, msg interface{}, contextIDList ...int64) error

sesDetector: 提供要发送到的目标session，发送msg消息，并携带ContextID

func ResoleveInboundEvent(inputEvent cellnet.Event) (ouputEvent cellnet.Event, handled bool)

处理入站的relay消息

func ResolveOutboundEvent(inputEvent cellnet.Event) (handled bool)

处理relay.Relay出站消息的日志

func SetBroadcaster(callback BroadcasterFunc)

设置广播函数, 回调时，按对应Peer/Session所在的队列中调用

type BroadcasterFunc func(event *RecvMsgEvent)

type RecvMsgEvent struct {
	Ses cellnet.Session
	Msg interface{}

	ContextID []int64
}

func (self *RecvMsgEvent) Message() interface{}

func (self *RecvMsgEvent) OneContextID() int64

func (self *RecvMsgEvent) RelayBack(msg interface{})

消息原路返回

func (self *RecvMsgEvent) Session() cellnet.Session

type RelayACK struct {
	MsgID     uint16
	Data      []byte
	ContextID []int64
}

func (self *RelayACK) String() string