gob

Documentation

Index

• Variables
• func Dial(network, address string) (chan IMsg, chan IMsg, 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) (chan IMsg, chan IMsg, 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) (chan IMsg, chan IMsg, 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 //返回对应的消息编号，每种消息一个编号，保证唯一性
}

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) (chan IMsg, chan IMsg, error)

type ServerError

type ServerError string

func (ServerError) Error

func (e ServerError) Error() string