echo

Documentation

Index

• type NotifyNewIO
  • func (n *NotifyNewIO) Msg() def.Msg
  • func (n *NotifyNewIO) PeerServID() def.ServID
  • func (n *NotifyNewIO) PeerServType() def.ServTP
  • func (n *NotifyNewIO) ReqID() int32
  • func (n *NotifyNewIO) Response(ctx context.Context, msg def.Msg) error
• type Server
  • func NewServer() *Server
  • func (s *Server) AfterInit() error
  • func (s *Server) AsyncConnectMe(ctx context.Context, raw net.Conn) error
  • func (s *Server) BeforeStop()
  • func (s *Server) Handle(ctx context.Context, req def.RequestWriter) error
  • func (s *Server) ID() def.ServID
  • func (s *Server) Init(srv *xserver.Server) error
  • func (s *Server) Loop(ctx context.Context, delta xtime.DeltaTimeMsec)
  • func (s *Server) Stop()
  • func (s *Server) Type() def.ServTP

Types

type NotifyNewIO

type NotifyNewIO struct {
	io.OuterIO
}

func (*NotifyNewIO) Msg

func (n *NotifyNewIO) Msg() def.Msg

func (*NotifyNewIO) PeerServID

func (n *NotifyNewIO) PeerServID() def.ServID

func (*NotifyNewIO) PeerServType

func (n *NotifyNewIO) PeerServType() def.ServTP

func (*NotifyNewIO) ReqID

func (n *NotifyNewIO) ReqID() int32

func (*NotifyNewIO) Response

func (n *NotifyNewIO) Response(ctx context.Context, msg def.Msg) error

type Server

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

func NewServer

func NewServer() *Server

func (*Server) AfterInit

func (s *Server) AfterInit() error

func (*Server) AsyncConnectMe

func (s *Server) AsyncConnectMe(ctx context.Context, raw net.Conn) error

AsyncConnectMe run in single goroutine.

func (*Server) BeforeStop

func (s *Server) BeforeStop()

func (*Server) Handle

func (s *Server) Handle(ctx context.Context, req def.RequestWriter) error

func (*Server) ID

func (s *Server) ID() def.ServID

func (*Server) Init

func (s *Server) Init(srv *xserver.Server) error

func (*Server) Loop

func (s *Server) Loop(ctx context.Context, delta xtime.DeltaTimeMsec)

func (*Server) Stop

func (s *Server) Stop()

func (*Server) Type

func (s *Server) Type() def.ServTP