plugin

Documentation

Index

• type DataHandler
• type DataItem
• type ServerBalancer
  • func NewServerBalancer() *ServerBalancer
  • func (b *ServerBalancer) AfterInit(s *rpc.ServerBase)
  • func (b *ServerBalancer) Balance(remoteAddr string) (*treaty.Server, error)
  • func (b *ServerBalancer) BeforeShutdown(s *rpc.ServerBase)
  • func (b *ServerBalancer) HandleBalance(w http.ResponseWriter, r *http.Request)
  • func (b *ServerBalancer) Init(s *rpc.ServerBase)
  • func (b *ServerBalancer) Run(s *rpc.ServerBase)
  • func (b *ServerBalancer) Shutdown(s *rpc.ServerBase)
  • func (b *ServerBalancer) WriteResponse(w http.ResponseWriter, msg proto.Message)
• type ServerConnector
  • func NewServerConnector() *ServerConnector
  • func (b *ServerConnector) AfterInit(s *rpc.ServerBase)
  • func (b *ServerConnector) BeforeShutdown(s *rpc.ServerBase)
  • func (b *ServerConnector) Init(s *rpc.ServerBase)
  • func (b *ServerConnector) Run(s *rpc.ServerBase)
  • func (b *ServerConnector) Shutdown(s *rpc.ServerBase)
• type ServerData
  • func NewServerData(dataHandler DataHandler, maxDbQueue, dbQueueSize int64) *ServerData
  • func (b *ServerData) AfterInit(s *rpc.ServerBase)
  • func (b *ServerData) BeforeShutdown(s *rpc.ServerBase)
  • func (b *ServerData) DealQueue(ctx context.Context, num int, queue chan *DataItem)
  • func (b *ServerData) DealReq(ctx context.Context, s *rpc.ServerBase)
  • func (b *ServerData) Init(s *rpc.ServerBase)
  • func (b *ServerData) Shutdown(s *rpc.ServerBase)
• type ServerHttp
  • func NewServerHttp(h rpc.HttpHandler) *ServerHttp
  • func (b *ServerHttp) AfterInit(s *rpc.ServerBase)
  • func (b *ServerHttp) BeforeShutdown(s *rpc.ServerBase)
  • func (b *ServerHttp) Init(s *rpc.ServerBase)
  • func (b *ServerHttp) Run(s *rpc.ServerBase)
  • func (b *ServerHttp) Shutdown(s *rpc.ServerBase)
• type ServerSocket
  • func NewServerSocket(ns string, ssl config.SslConf, opts *engineio.Options) *ServerSocket
  • func (b *ServerSocket) AfterInit(s *rpc.ServerBase)
  • func (b *ServerSocket) BeforeShutdown(s *rpc.ServerBase)
  • func (b *ServerSocket) Init(s *rpc.ServerBase)
  • func (b *ServerSocket) OnConnect(f func(socketio.Conn) error)
  • func (b *ServerSocket) OnDisconnect(f func(socketio.Conn, string))
  • func (b *ServerSocket) OnError(f func(socketio.Conn, error))
  • func (b *ServerSocket) OnEvent(event string, f interface{})
  • func (b *ServerSocket) Run(s *rpc.ServerBase)
  • func (b *ServerSocket) Shutdown(s *rpc.ServerBase)

Types

type DataHandler

type DataHandler func(item *DataItem)

type DataItem

type DataItem struct {
	UserId int64 `json:"user_id"`
	MsgId  int32 `json:"msg_id"`
	MsgReq any   `json:"msg_req"`
}

type ServerBalancer

type ServerBalancer struct {
	ClientServer *http.Server
	ClientCoder  serialize.Serializer
}

func NewServerBalancer

func NewServerBalancer() *ServerBalancer

func (*ServerBalancer) AfterInit

func (b *ServerBalancer) AfterInit(s *rpc.ServerBase)

func (*ServerBalancer) Balance

func (b *ServerBalancer) Balance(remoteAddr string) (*treaty.Server, error)

func (*ServerBalancer) BeforeShutdown

func (b *ServerBalancer) BeforeShutdown(s *rpc.ServerBase)

func (*ServerBalancer) HandleBalance

func (b *ServerBalancer) HandleBalance(w http.ResponseWriter, r *http.Request)

func (*ServerBalancer) Init

func (b *ServerBalancer) Init(s *rpc.ServerBase)

func (*ServerBalancer) Run

func (b *ServerBalancer) Run(s *rpc.ServerBase)

func (*ServerBalancer) Shutdown

func (b *ServerBalancer) Shutdown(s *rpc.ServerBase)

func (*ServerBalancer) WriteResponse

func (b *ServerBalancer) WriteResponse(w http.ResponseWriter, msg proto.Message)

type ServerConnector

type ServerConnector struct {
	ClientServer tcpface.IServer         //client server
	RouteHandler func(s tcpface.IServer) //注册路由
}

func NewServerConnector

func NewServerConnector() *ServerConnector

func (*ServerConnector) AfterInit

func (b *ServerConnector) AfterInit(s *rpc.ServerBase)

func (*ServerConnector) BeforeShutdown

func (b *ServerConnector) BeforeShutdown(s *rpc.ServerBase)

func (*ServerConnector) Init

func (b *ServerConnector) Init(s *rpc.ServerBase)

func (*ServerConnector) Run

func (b *ServerConnector) Run(s *rpc.ServerBase)

func (*ServerConnector) Shutdown

func (b *ServerConnector) Shutdown(s *rpc.ServerBase)

type ServerData

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

func NewServerData

func NewServerData(dataHandler DataHandler, maxDbQueue, dbQueueSize int64) *ServerData

func (*ServerData) AfterInit

func (b *ServerData) AfterInit(s *rpc.ServerBase)

func (*ServerData) BeforeShutdown

func (b *ServerData) BeforeShutdown(s *rpc.ServerBase)

func (*ServerData) DealQueue

func (b *ServerData) DealQueue(ctx context.Context, num int, queue chan *DataItem)

func (*ServerData) DealReq

func (b *ServerData) DealReq(ctx context.Context, s *rpc.ServerBase)

func (*ServerData) Init

func (b *ServerData) Init(s *rpc.ServerBase)

func (*ServerData) Shutdown

func (b *ServerData) Shutdown(s *rpc.ServerBase)

type ServerHttp

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

func NewServerHttp

func NewServerHttp(h rpc.HttpHandler) *ServerHttp

func (*ServerHttp) AfterInit

func (b *ServerHttp) AfterInit(s *rpc.ServerBase)

func (*ServerHttp) BeforeShutdown

func (b *ServerHttp) BeforeShutdown(s *rpc.ServerBase)

func (*ServerHttp) Init

func (b *ServerHttp) Init(s *rpc.ServerBase)

func (*ServerHttp) Run

func (b *ServerHttp) Run(s *rpc.ServerBase)

func (*ServerHttp) Shutdown

func (b *ServerHttp) Shutdown(s *rpc.ServerBase)

type ServerSocket

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

func NewServerSocket

func NewServerSocket(ns string, ssl config.SslConf, opts *engineio.Options) *ServerSocket

func (*ServerSocket) AfterInit

func (b *ServerSocket) AfterInit(s *rpc.ServerBase)

func (*ServerSocket) BeforeShutdown

func (b *ServerSocket) BeforeShutdown(s *rpc.ServerBase)

func (*ServerSocket) Init

func (b *ServerSocket) Init(s *rpc.ServerBase)

func (*ServerSocket) OnConnect

func (b *ServerSocket) OnConnect(f func(socketio.Conn) error)

func (*ServerSocket) OnDisconnect

func (b *ServerSocket) OnDisconnect(f func(socketio.Conn, string))

func (*ServerSocket) OnError

func (b *ServerSocket) OnError(f func(socketio.Conn, error))

func (*ServerSocket) OnEvent

func (b *ServerSocket) OnEvent(event string, f interface{})

func (*ServerSocket) Run

func (b *ServerSocket) Run(s *rpc.ServerBase)

func (*ServerSocket) Shutdown

func (b *ServerSocket) Shutdown(s *rpc.ServerBase)