server

Documentation

Index

• Variables
• func RecvChanEveryNew(cfg interface{}) func() chan *protocol.Packet
• type FNewReceiver
• type NewListener
• type Receiver
  • func (r *Receiver) Armour() conn.Armour
  • func (r *Receiver) BindArmour(a conn.Armour)
  • func (r *Receiver) Close()
  • func (r *Receiver) Done() <-chan struct{}
  • func (r *Receiver) ID() uint64
  • func (r *Receiver) OnNetClosed()
  • func (r *Receiver) RecvChan() <-chan *protocol.Packet
  • func (r *Receiver) Response(reqHeader *protocol.Header, rsp protocol.Message) error
  • func (r *Receiver) ResponseWithError(reqHeader *protocol.Header, ec uint32, em string) error
  • func (r *Receiver) Send(msg protocol.Message) error
  • func (r *Receiver) Sender() *conn.Sender
• type RecvChanEveryNewConfig
• type Server
  • func (s *Server) Start() error
  • func (s *Server) Stop()
• type ServerConfig

Variables

var DefaultFRecvChan conn.FRecvChan

var (
	ErrNoFNewReceiver = errors.New("must set FNewReceiver callback function to Server instance")
)

var ServerVersion = "0.0.1"

Functions

func RecvChanEveryNew

func RecvChanEveryNew(cfg interface{}) func() chan *protocol.Packet

Types

type FNewReceiver

type FNewReceiver func(r *Receiver)

type NewListener

type NewListener func(cfg interface{}) (conn.Listener, error)

var DefaultNewListener NewListener

type Receiver

type Receiver struct {
	Conn conn.Connection

	CBOnNetClosed func(*Receiver)
	// contains filtered or unexported fields
}

接收者实例, 一个已建立的客户端连接, 管理客户端连接的状态和消息收发. 对用户代码而言, 一个Receiver实例就是一个客户端

func (*Receiver) Armour

func (r *Receiver) Armour() conn.Armour

func (*Receiver) BindArmour

func (r *Receiver) BindArmour(a conn.Armour)

func (*Receiver) Close

func (r *Receiver) Close()

func (*Receiver) Done

func (r *Receiver) Done() <-chan struct{}

func (*Receiver) ID

func (r *Receiver) ID() uint64

func (*Receiver) OnNetClosed

func (r *Receiver) OnNetClosed()

func (*Receiver) RecvChan

func (r *Receiver) RecvChan() <-chan *protocol.Packet

func (*Receiver) Response

func (r *Receiver) Response(reqHeader *protocol.Header, rsp protocol.Message) error

func (*Receiver) ResponseWithError

func (r *Receiver) ResponseWithError(reqHeader *protocol.Header, ec uint32, em string) error

func (*Receiver) Send

func (r *Receiver) Send(msg protocol.Message) error

func (*Receiver) Sender

func (r *Receiver) Sender() *conn.Sender

type RecvChanEveryNewConfig

type RecvChanEveryNewConfig struct {
	QueueLen int `json:"queueLen,omitempty"`
}

type Server

type Server struct {
	Config       *ServerConfig
	NewListener  NewListener
	FRecvChan    conn.FRecvChan
	FNewReceiver FNewReceiver
	// contains filtered or unexported fields
}

服务对象定义

func (*Server) Start

func (s *Server) Start() error

func (*Server) Stop

func (s *Server) Stop()

type ServerConfig

type ServerConfig struct {
	Listener interface{}
}