The highest tagged major version is
Documentation
¶
Index ¶
- type BaseBalancer
- func (b *BaseBalancer) AfterInit()
- func (b *BaseBalancer) Balance(remoteAddr string) (*treaty.Server, error)
- func (b *BaseBalancer) BeforeShutdown()
- func (b *BaseBalancer) GetServer() *treaty.Server
- func (b *BaseBalancer) GetServerId() string
- func (b *BaseBalancer) HandleBalance(w http.ResponseWriter, r *http.Request)
- func (b *BaseBalancer) Init()
- func (b *BaseBalancer) RegEventHandlerBroadcast(handler rpcx.CallbackFunc)
- func (b *BaseBalancer) RegEventHandlerSelf(handler rpcx.CallbackFunc)
- func (b *BaseBalancer) RegEventJsonSelf(handler rpcx.CallbackFunc)
- func (b *BaseBalancer) SetServerId(serverId string)
- func (b *BaseBalancer) Shutdown()
- func (b *BaseBalancer) WriteResponse(w http.ResponseWriter, msg proto.Message)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseBalancer ¶
type BaseBalancer struct {
ServerId string
Server *treaty.Server
RpcX rpcx.RpcServer
ClientServer *http.Server
ClientCoder serialize.Serializer
EventJsonSelf rpcx.CallbackFunc //处理自己的json事件
EventHandlerSelf rpcx.CallbackFunc //处理自己的事件
EventHandlerBroadcast rpcx.CallbackFunc //处理广播事件
}
func (*BaseBalancer) AfterInit ¶
func (b *BaseBalancer) AfterInit()
func (*BaseBalancer) Balance ¶
func (b *BaseBalancer) Balance(remoteAddr string) (*treaty.Server, error)
func (*BaseBalancer) BeforeShutdown ¶
func (b *BaseBalancer) BeforeShutdown()
func (*BaseBalancer) GetServer ¶
func (b *BaseBalancer) GetServer() *treaty.Server
func (*BaseBalancer) GetServerId ¶
func (b *BaseBalancer) GetServerId() string
func (*BaseBalancer) HandleBalance ¶
func (b *BaseBalancer) HandleBalance(w http.ResponseWriter, r *http.Request)
func (*BaseBalancer) Init ¶
func (b *BaseBalancer) Init()
func (*BaseBalancer) RegEventHandlerBroadcast ¶
func (b *BaseBalancer) RegEventHandlerBroadcast(handler rpcx.CallbackFunc)
func (*BaseBalancer) RegEventHandlerSelf ¶
func (b *BaseBalancer) RegEventHandlerSelf(handler rpcx.CallbackFunc)
func (*BaseBalancer) RegEventJsonSelf ¶
func (b *BaseBalancer) RegEventJsonSelf(handler rpcx.CallbackFunc)
func (*BaseBalancer) SetServerId ¶
func (b *BaseBalancer) SetServerId(serverId string)
func (*BaseBalancer) Shutdown ¶
func (b *BaseBalancer) Shutdown()
func (*BaseBalancer) WriteResponse ¶
func (b *BaseBalancer) WriteResponse(w http.ResponseWriter, msg proto.Message)
Source Files
Click to show internal directories.
Click to hide internal directories.