gob

Documentation

Index

• Variables
• func Dial(network, address string) (channel.IChanN, channel.IChanN, error)
• func Register(msg IMsg) (err error)
• type Codec
• type Header
• type IMsg
• type Peer
  • func NewPeer() *Peer
  • func (p *Peer) ServeConn(conn io.ReadWriteCloser) (channel.IChanN, channel.IChanN, error)
• type ServerError
  • func (e ServerError) Error() string

Variables

var ErrNotSuportType = errors.New("type is not suported")

var ErrPendingTooLong = errors.New("call is pending too long")

var ErrSendError = errors.New("got error when send to network")

var ErrShutdown = errors.New("connection is shut down")

Functions

func Dial

func Dial(network, address string) (channel.IChanN, channel.IChanN, error)

func Register

func Register(msg IMsg) (err error)

Register msg要先注册后，才能正确接收该类型的数据

Types

type Codec

type Codec interface {
	ReadHeader(*Header) error
	ReadBody(interface{}) error
	// Write must be safe for concurrent use by multiple goroutines.
	Write(header *Header, body interface{}) error

	Close() error
}

type Header

type Header struct {
	MsgNO uint32 //
	// contains filtered or unexported fields
}

type IMsg

type IMsg interface {
	RecvMsg(connID int, logT *log.TraceInfoST) //消息的处理过程
	MsgNO() uint16                             //返回对应的消息编号，每种消息一个编号，保证唯一性
	MsgTimestamp() int64                       //消息是具有时效性的
}

IMsg 是路由层(消息分发层)和逻辑层(消息处理层)之间传递的数据结构,Msg:message的缩写

type Peer

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

Peer 一条连接一个Peer，连接的相关的信息可以存这里

func NewPeer

func NewPeer() *Peer

NewPeer returns a new Peer.

func (*Peer) ServeConn

func (p *Peer) ServeConn(conn io.ReadWriteCloser) (channel.IChanN, channel.IChanN, error)

type ServerError

type ServerError string

func (ServerError) Error

func (e ServerError) Error() string