relay

package

v1.0.0 Latest Latest Go to latest Published: Nov 13, 2018 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Languege/cellnet

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Relay(sesDetector, payload, passThrough 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
type RecvMsgEvent
type RelayACK

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrRelayPacketCrack       = errors.New("invalid relay packet format")
	ErrUnknownPassThroughKind = errors.New("Unknown PassThrough kind")
)

View Source

var (
	ErrInvalidPeerSession = errors.New("Require valid cellnet.Session or cellnet.TCPConnector")
)

Functions ¶

func Relay ¶

func Relay(sesDetector, payload, passThrough interface{}) error

sesDetector: 提供要发送到的目标session，传输msg消息，透传passThroughData

func ResoleveInboundEvent ¶

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

处理入站的relay消息

func ResolveOutboundEvent ¶

func ResolveOutboundEvent(inputEvent cellnet.Event) (handled bool, err error)

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

func SetBroadcaster ¶

func SetBroadcaster(callback BroadcasterFunc)

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

Types ¶

type BroadcasterFunc ¶

type BroadcasterFunc func(event *RecvMsgEvent)

type RecvMsgEvent ¶

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

	PassThrough interface{}
}

func (*RecvMsgEvent) Message ¶

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

func (*RecvMsgEvent) PassThroughAsInt64 ¶

func (self *RecvMsgEvent) PassThroughAsInt64() int64

func (*RecvMsgEvent) PassThroughAsInt64Slice ¶

func (self *RecvMsgEvent) PassThroughAsInt64Slice() []int64

func (*RecvMsgEvent) Reply ¶

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

消息原路返回

func (*RecvMsgEvent) Session ¶

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

type RelayACK ¶

type RelayACK struct {
	PayloadMsgID uint16
	Payload      []byte // 用户原消息

	PassThroughKind  uint8
	PassThroughMsgID uint16
	PassThrough      []byte // 透传数据
}

func (*RelayACK) Decode ¶

func (self *RelayACK) Decode() (payload, passThrough interface{}, err error)

func (*RelayACK) Encode ¶

func (self *RelayACK) Encode(payload, passThrough interface{}) (err error)

func (*RelayACK) String ¶

func (self *RelayACK) String() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL