Versions in this module Expand all Collapse all v0 v0.0.0 Aug 5, 2022 Changes in this version + var ErrInvalidPeerSession = errors.New("Require valid cellnet.Session or cellnet.TCPConnector") + func Relay(sesDetector interface{}, dataList ...interface{}) error + func ResoleveInboundEvent(inputEvent cellnet.Event) (ouputEvent cellnet.Event, handled bool, err error) + func ResolveOutboundEvent(inputEvent cellnet.Event) (handled bool, err error) + func SetBroadcaster(callback BroadcasterFunc) + type BroadcasterFunc func(event *RecvMsgEvent) + type PassthroughContent struct + Int64 int64 + Int64Slice []int64 + Str string + type RecvMsgEvent struct + Msg interface{} + Ses cellnet.Session + func (self *RecvMsgEvent) Message() interface{} + func (self *RecvMsgEvent) PassThroughAsInt64() int64 + func (self *RecvMsgEvent) PassThroughAsInt64Slice() []int64 + func (self *RecvMsgEvent) PassThroughAsString() string + func (self *RecvMsgEvent) Reply(msg interface{}) + func (self *RecvMsgEvent) Session() cellnet.Session + type RelayACK struct + Bytes []byte + Int64 int64 + Int64Slice []int64 + Msg []byte + MsgID uint32 + Str string + func (self *RelayACK) Marshal(buffer *proto.Buffer) error + func (self *RelayACK) Size() (ret int) + func (self *RelayACK) String() string + func (self *RelayACK) Unmarshal(buffer *proto.Buffer, fieldIndex uint64, wt proto.WireType) error
Go to main page