Versions in this module Expand all Collapse all v2 v2.3.2 Nov 22, 2023 v2.3.1 Nov 22, 2023 Changes in this version + type HandlerPool struct + func NewHandlerPool() *HandlerPool + func (h *HandlerPool) GetHandlers() map[string]*component.Handler + func (h *HandlerPool) ProcessHandlerMessage(ctx context.Context, rt *route.Route, serializer serialize.Serializer, ...) ([]byte, error) + func (h *HandlerPool) Register(serviceName string, name string, handler *component.Handler) + type HandlerService struct + func NewHandlerService(packetDecoder codec.PacketDecoder, serializer serialize.Serializer, ...) *HandlerService + func (h *HandlerService) Dispatch(thread int) + func (h *HandlerService) Docs(getPtrNames bool) (map[string]interface{}, error) + func (h *HandlerService) DumpServices() + func (h *HandlerService) Handle(conn acceptor.PlayerConn) + func (h *HandlerService) Register(comp component.Component, opts []component.Option) error + func (h *HandlerService) SetHandlerHooks(handlerHooks *pipeline.HandlerHooks) + type RemoteService struct + func NewRemoteService(rpcClient cluster.RPCClient, rpcServer cluster.RPCServer, ...) *RemoteService + func (h *RemoteService) SetHandlerHooks(handlerHooks *pipeline.HandlerHooks) + func (r *RemoteService) AddRemoteBindingListener(bindingListener cluster.RemoteBindingListener) + func (r *RemoteService) Call(ctx context.Context, req *protos.Request) (*protos.Response, error) + func (r *RemoteService) DoRPC(ctx context.Context, serverID string, route *route.Route, protoData []byte) (*protos.Response, error) + func (r *RemoteService) Docs(getPtrNames bool) (map[string]interface{}, error) + func (r *RemoteService) DumpServices() + func (r *RemoteService) KickUser(ctx context.Context, kick *protos.KickMsg) (*protos.KickAnswer, error) + func (r *RemoteService) PushToUser(ctx context.Context, push *protos.Push) (*protos.Response, error) + func (r *RemoteService) RPC(ctx context.Context, serverID string, route *route.Route, reply proto.Message, ...) error + func (r *RemoteService) Register(comp component.Component, opts []component.Option) error + func (r *RemoteService) SessionBindRemote(ctx context.Context, msg *protos.BindMsg) (*protos.Response, error)