Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrDuplicateChannel = errors.New("duplicate channel") ErrChannelNotFound = errors.New("channel not found") )
View Source
var (
ErrProtoIDNotFound = errors.New("proto id not found")
)
Functions ¶
Types ¶
type FutuDecoder ¶
type FutuDecoder struct {
// contains filtered or unexported fields
}
func NewDecoder ¶
func NewDecoder(reg *Registry) *FutuDecoder
type FutuEncoder ¶
type FutuEncoder struct {
// contains filtered or unexported fields
}
func NewEncoder ¶
func NewEncoder(proto uint32, serial uint32, msg proto.Message) *FutuEncoder
type PBChan ¶
type PBChan struct {
// contains filtered or unexported fields
}
用于接收到数据后,发送协议数据到接收goroutine
type Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
Registry 接收数据处理器注册表
func (*Registry) AddGetChan ¶
AddGetChan 添加get方法的接收通道
func (*Registry) AddUpdateChan ¶
AddUpdateChan 添加update方法的接收通道
Click to show internal directories.
Click to hide internal directories.