protocol

package

v0.1.3 Latest Latest Go to latest Published: Mar 12, 2022 License: MIT Imports: 11 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

This section is empty.

View Source

var (
	ErrDuplicateChannel = errors.New("duplicate channel")
	ErrChannelNotFound  = errors.New("channel not found")
)

View Source

var (
	ErrProtoIDNotFound = errors.New("proto id not found")
)

func Error(r Response) error

type FutuDecoder struct {
	// contains filtered or unexported fields
}

func NewDecoder(reg *Registry) *FutuDecoder

func (de *FutuDecoder) ReadFrom(c net.Conn) (tcp.Handler, error)

type FutuEncoder struct {
	// contains filtered or unexported fields
}

func NewEncoder(proto uint32, serial uint32, msg proto.Message) *FutuEncoder

func (en *FutuEncoder) WriteTo(c net.Conn) error

type PBChan struct {
	// contains filtered or unexported fields
}

用于接收到数据后，发送协议数据到接收goroutine

func NewPBChan(i interface{}) (*PBChan, error)

func (ch *PBChan) Close()

func (ch *PBChan) Send(b []byte) error

type Registry struct {
	// contains filtered or unexported fields
}

Registry 接收数据处理器注册表

func NewRegistry() *Registry

NewRegistry 生成新的Registry

func (reg *Registry) AddGetChan(proto uint32, serial uint32, ch RespChan) error

AddGetChan 添加get方法的接收通道

func (reg *Registry) AddUpdateChan(proto uint32, ch RespChan) error

AddUpdateChan 添加update方法的接收通道

func (reg *Registry) Close()

Close 关闭Registry的worker

func (reg *Registry) RemoveChan(proto uint32, serial uint32) error

type RespChan interface {
	Send(b []byte) error
	Close()
}

type Response interface {
	GetRetType() int32
	GetRetMsg() string
}