Documentation
¶
Index ¶
- Constants
- Variables
- func IsServerStopping() bool
- func SetServerStopping()
- type Actor
- type IServer
- type Options
- func (p *Options) WithEtcd(etcd *xetcd.Options) *Options
- func (p *Options) WithHeaderStrategy(strategy xpacket.IHeaderStrategy) *Options
- func (p *Options) WithKCPHandler(handler xnetcommon.IHandler) *Options
- func (p *Options) WithLogCallbackFunc(callback xcontrol.ICallBack) *Options
- func (p *Options) WithTCPHandler(handler xnetcommon.IHandler) *Options
- func (p *Options) WithWebsocketHandler(handler xnetcommon.IHandler) *Options
- type Server
- func (p *Server) GetActor() *Actor
- func (p *Server) GetOptions() (opt *Options)
- func (p *Server) PostStart() error
- func (p *Server) PreStart(ctx context.Context, opts ...*Options) error
- func (p *Server) PreStop() error
- func (p *Server) Start(ctx context.Context) (err error)
- func (p *Server) Stop() (err error)
Constants ¶
View Source
const ReportIntervalSecondDefault int64 = 30 // etcd-上报时间间隔 秒
Variables ¶
View Source
var GServerStatus uint32
Functions ¶
Types ¶
type IServer ¶
type IServer interface {
PreStart(ctx context.Context, opts ...*Options) (err error) // 服务启动前的处理 - 资源准备
Start(ctx context.Context) (err error) // 启动服务
PostStart() (err error) // 服务启动后的处理 - 资源准备完成
PreStop() (err error) // 服务关闭前的处理 - 关闭资源前
Stop() (err error) // 停止服务 - 关闭 bus 之后
GetOptions() (opt *Options)
}
type Options ¶
type Options struct {
TCPHandler xnetcommon.IHandler
KCPHandler xnetcommon.IHandler
WebsocketHandler xnetcommon.IHandler
LogCallback xcontrol.ICallBack
HeaderStrategy xpacket.IHeaderStrategy
Etcd *xetcd.Options
}
func (*Options) WithHeaderStrategy ¶
func (p *Options) WithHeaderStrategy(strategy xpacket.IHeaderStrategy) *Options
func (*Options) WithKCPHandler ¶
func (p *Options) WithKCPHandler(handler xnetcommon.IHandler) *Options
func (*Options) WithLogCallbackFunc ¶
func (*Options) WithTCPHandler ¶
func (p *Options) WithTCPHandler(handler xnetcommon.IHandler) *Options
func (*Options) WithWebsocketHandler ¶
func (p *Options) WithWebsocketHandler(handler xnetcommon.IHandler) *Options
Source Files
¶
Click to show internal directories.
Click to hide internal directories.