Versions in this module Expand all Collapse all v1 v1.0.2 Nov 16, 2024 v1.0.1 Nov 16, 2024 Changes in this version + type MsgHandler func([]interface{}) + type MsgInfo struct + type MsgRaw struct + type Processor struct + func NewProcessor() *Processor + func (p *Processor) Marshal(msg interface{}) ([][]byte, error) + func (p *Processor) Register(msg interface{}) string + func (p *Processor) Route(msg interface{}, userData interface{}) error + func (p *Processor) SetHandler(msg interface{}, msgHandler MsgHandler) + func (p *Processor) SetRawHandler(msgID string, msgRawHandler MsgHandler) + func (p *Processor) SetRouter(msg interface{}, msgRouter *chanrpc.Server) + func (p *Processor) Unmarshal(data []byte) (interface{}, error)
Go to main page