rpc

package

Go to main page

Versions in this module

v1

v1.0.20

Jan 11, 2025

v1.0.19

Jan 4, 2025

Changes in this version

type Module

+ func (m *Module) AddUserLoginHook(hook loginHook)

+ func (m *Module) AddUserOfflineHook(hook offlineHook)

+ func (m *Module) LoginHook(ctx context.Context, args *DefaultArgs, reply *EmptyReply) (err error)

+ func (m *Module) OfflineHook(ctx context.Context, args *OfflineReq, reply *EmptyReply) (err error)

v1.0.18

Aug 2, 2024

Changes in this version

+ func SendAllUserToGate(messageType string, pbMessage proto.Message, userIds []string) error

+ func SendToGateSync(ct context.Context, messageType string, pbMessage proto.Message) error

v1.0.16

May 31, 2024

Changes in this version

type Module

+ func (m *Module) GetName() string

+ func (m *Module) GetVersion() string

v1.0.15

Apr 17, 2024

v1.0.14

Apr 10, 2024

v1.0.13

Apr 2, 2024

v1.0.12

Mar 28, 2024

Changes in this version

type IService

+ GetLogicSyncMethod func() []string

type Module

+ func (m *Module) GetLogicSyncMethod() []string

v1.0.11

Mar 27, 2024

Changes in this version

+ func BorderAllServiceRPCMessageByContextNotCheck[Req any, Res any](ct context.Context, api *ServiceAPI[Req, Res])

+ func SendRPCMessageByStr(ct context.Context, moduleName, serviceName string, args, reply interface{}) error

v1.0.10

Mar 13, 2024

v1.0.9

Feb 29, 2024

Changes in this version

+ func CorsMiddleware(handler http.HandlerFunc) http.HandlerFunc

+ func NewRPCXServerHandler() server.PostCallPlugin

+ func SendNoReplyRPCMessageByAddress(moduleName, address, serviceName string, args interface{}) error

+ func ServeAdmin()

+ type Admin struct

+ func (a *Admin) Destroy(sub IService)

+ func (a *Admin) GetName() string

+ func (a *Admin) GetUserHook() IUserHook

+ func (a *Admin) GetVersion() string

+ func (a *Admin) L(ctx context.Context, args *string, reply *string) (err error)

+ func (a *Admin) Startup() (bool, error)

+ type ConsulServerInfo struct

+ NodeId string

+ State string

+ SubVersion int32

+ Version int32

type ITCPBuilder

+ IsWss func() bool

+ WithWss func(certFile, keyFile string) ITCPBuilder

+ WssCertFile func() string

+ WssKeyFile func() string

type Module

+ State client.ConsulServerState

+ func (m *Module) StateHandler(ctx context.Context, args *client.ConsulServerState, reply *string) (err error)

+ type MonitorService struct

+ func (m *MonitorService) ASyncMonitor(ctx context.Context, args *string, reply *admin.NodeMonitorData) (err error)

+ func (m *MonitorService) GetName() string

+ func (m *MonitorService) GetVersion() string

+ func (m *MonitorService) Startup() (bool, error)

type RequestData

+ StartTime time.Time

type Server

+ func (s *Server) WithGatewayWSS(port, path, key, cert string) *Server

type ServerConfig

+ func (s *ServerConfig) IsWss() bool

+ func (s *ServerConfig) WithWss(certFile, keyFile string) ITCPBuilder

+ func (s *ServerConfig) WssCertFile() string

+ func (s *ServerConfig) WssKeyFile() string

type ServiceAPI

+ func (s *ServiceAPI[Req, Res]) NewRPC(req Req) *ServiceAPI[Req, Res]

type UserConnectData

+ func (u *UserConnectData) StartReq()

+ type XClientHandler struct

+ func (r *XClientHandler) PostCall(ctx context.Context, servicePath, serviceMethod string, args interface{}, ...) error

+ func (r *XClientHandler) PreCall(ctx context.Context, serviceName, methodName string, args interface{}) error

+ type XServerHandler struct

+ func (r *XServerHandler) PostCall(ctx context.Context, servicePath, serviceMethod string, args interface{}, ...) (result interface{}, e error)

+ func (r *XServerHandler) PostReadRequest(ctx context.Context, m *protocol.Message, e error) error

+ func (r *XServerHandler) PreCall(ctx context.Context, serviceName, methodName string, args interface{}) (result interface{}, e error)

v1.0.8

Feb 23, 2024

v1.0.7

Feb 19, 2024

Changes in this version

type IService

+ GetUserHook func() IUserHook

type Module

+ func (m *Module) GetUserHook() IUserHook

v1.0.6

Dec 26, 2023

v1.0.5

Dec 26, 2023

Changes in this version

+ var File_ws_proto protoreflect.FileDescriptor

type WSResponse

+ Zip bool

+ func (x *WSResponse) GetZip() bool

v1.0.4

Dec 18, 2023

v1.0.3

Dec 12, 2023

v1.0.2

Dec 10, 2023

Changes in this version

type LoginRes

+ func UserLogin(ctx context.Context, userId string) (*LoginRes, error)

v1.0.1

Dec 9, 2023

v1.0.0

Dec 7, 2023

Changes in this version

+ var File_Users_AUSA_Documents_IdeaProject_tgf_example_kit_proto_ws_proto protoreflect.FileDescriptor

+ var Gate = &Module

+ var Login = &ServiceAPI[*LoginReq, *LoginRes]

+ var Offline = &ServiceAPI[*OfflineReq, *OfflineRes]

+ var ToUser = &ServiceAPI[*ToUserReq, *ToUserRes]

+ var UploadUserNodeInfo = &ServiceAPI[*UploadUserNodeInfoReq, *UploadUserNodeInfoRes]

+ func BorderAllServiceRPCMessageByContext[Req any, Res any](ct context.Context, api *ServiceAPI[Req, Res])

+ func BorderRPCMessage[Req any, Res any](ct context.Context, api *ServiceAPI[Req, Res])

+ func GetNodeId(ctx context.Context) string

+ func GetTemplateUserId(ctx context.Context) string

+ func GetUserId(ctx context.Context) string

+ func NewBindRPCContext(userId ...string) context.Context

+ func NewCacheUserContext(userId string) context.Context

+ func NewCustomSelector(moduleName string) client2.Selector

+ func NewRPCContext() context.Context

+ func NewRPCXClientHandler() client2.PostCallPlugin

+ func NewUserRPCContext(userId string) context.Context

+ func SendNoReplyRPCMessage[Req any, Res any](ct context.Context, api *ServiceAPI[Req, Res]) error

+ func SendRPCMessage[Req any, Res any](ct context.Context, api *ServiceAPI[Req, Res]) (res Res, err error)

+ func SendToGate(ct context.Context, messageType string, pbMessage proto.Message) error

+ func SendToGateByUserId(userId, messageType string, pbMessage proto.Message) error

+ type Args struct

+ ByteData []byte

+ func (a *Args[T]) GetData() (res T)

+ type Call struct

+ func SendAsyncRPCMessage[Req any, Res any](ct context.Context, api *ServiceAPI[Req, Res]) (*Call, error)

+ func (this *Call) Done() error

+ type Client struct

+ func (this *Client) AddWhiteService(serviceName string) *Client

+ func (this *Client) CheckWhiteList(serviceName string) bool

+ type ClientOptional struct

+ type CustomSelector struct

+ func (this *CustomSelector) Select(ctx context.Context, servicePath, serviceMethod string, args interface{}) (selected string)

+ func (this *CustomSelector) UpdateServer(servers map[string]string)

+ type DefaultArgs struct

+ C string

+ type DefaultBool struct

+ C bool

+ type DefaultReply struct

+ C int32

+ type EmptyReply struct

+ type GateService struct

+ func (this *GateService) GetName() string

+ func (this *GateService) GetVersion() string

+ func (this *GateService) Login(ctx context.Context, args *LoginReq, reply *LoginRes) error

+ func (this *GateService) Offline(ctx context.Context, args *OfflineReq, reply *OfflineRes) error

+ func (this *GateService) Startup() (bool, error)

+ func (this *GateService) ToUser(ctx context.Context, args *ToUserReq, reply *ToUserRes) error

+ func (this *GateService) UploadUserNodeInfo(ctx context.Context, args *UploadUserNodeInfoReq, reply *UploadUserNodeInfoRes) error

+ type HeaderMessageType byte

+ const Heartbeat

+ const Logic

+ const ReplaceLogin

+ type ILoginCheck interface

+ CheckLogin func(token string) (bool, string)

+ type IService interface

+ Destroy func(sub IService)

+ GetName func() string

+ GetVersion func() string

+ Startup func() (bool, error)

+ func GatewayService(tcpBuilder ITCPBuilder) IService

+ type ITCPBuilder interface

+ Address func() string

+ DeadLineTime func() time.Duration

+ IsWebSocket func() bool

+ MaxConnections func() int32

+ Port func() string

+ ReadBufferSize func() int

+ SetUserHook func(userHook IUserHook)

+ UserHook func() IUserHook

+ WithBuffer func(readBuffer, writeBuffer int) ITCPBuilder

+ WithPort func(port string) ITCPBuilder

+ WithWSPath func(path string) ITCPBuilder

+ WriteBufferSize func() int

+ WsPath func() string

+ type ITCPService interface

+ DoLogin func(userId, templateUserId string) (err error)

+ Offline func(userId string, replace bool) (exists bool)

+ Run func()

+ ToUser func(userId, messageType string, data []byte)

+ UpdateUserNodeInfo func(userId, servicePath, nodeId string) bool

+ type IUserConnectData interface

+ GetChannel func() chan *client.Call

+ GetContextData func() *share.Context

+ IsLogin func() bool

+ Login func(userId string)

+ Offline func(userHook IUserHook)

+ Send func(data []byte)

+ Stop func()

+ UpdateUserNodeId func(servicePath, nodeId string)

+ type IUserHook interface

+ AddLoginHook func(hook *ServiceAPI[*DefaultArgs, *EmptyReply]) IUserHook

+ AddOfflineHook func(hook *ServiceAPI[*DefaultArgs, *EmptyReply]) IUserHook

+ GetLoginHooks func() []*ServiceAPI[*DefaultArgs, *EmptyReply]

+ GetOfflineHooks func() []*ServiceAPI[*DefaultArgs, *EmptyReply]

+ func NewUserHook() IUserHook

+ type LoginReq struct

+ TemplateUserId string

+ UserId string

+ type LoginRes struct

+ ErrorCode int32

+ type Module struct

+ Name string

+ Version string

+ func (this *Module) Destroy(sub IService)

+ type OfflineReq struct

+ Replace bool

+ UserId string

+ type OfflineRes struct

+ ErrorCode int32

+ type Optional func(*Server)

+ type RPCXClientHandler struct

+ func (this *RPCXClientHandler) PostCall(ctx context2.Context, servicePath, serviceMethod string, args interface{}, ...) error

+ func (this *RPCXClientHandler) PreCall(ctx context2.Context, serviceName, methodName string, args interface{}) (interface{}, error)

+ type Reply struct

+ ByteData []byte

+ Code int32

+ func (r *Reply[T]) SetCode(code int32)

+ func (r *Reply[T]) SetData(data T) (err error)

+ type RequestData struct

+ Data []byte

+ MessageType HeaderMessageType

+ Module string

+ ReqId int32

+ RequestMethod string

+ User *UserConnectData

+ type RequestHeader []byte

+ type ResponseHeader []byte

+ type Server struct

+ func NewRPCServer() *Server

+ func (this *Server) Destroy()

+ func (this *Server) Run() chan bool

+ func (this *Server) WithCache(module tgf.CacheModule) *Server

+ func (this *Server) WithCustomServiceAddress()

+ func (this *Server) WithGameConfig(path string) *Server

+ func (this *Server) WithGateway(port string, hook IUserHook) *Server

+ func (this *Server) WithGatewayWS(port, path string, hook IUserHook) *Server

+ func (this *Server) WithProfileDebug() *Server

+ func (this *Server) WithRandomServicePort(minPort, maxPort int32) *Server

+ func (this *Server) WithServerPool(maxWorkers, maxCapacity int) *Server

+ func (this *Server) WithService(service IService) *Server

+ func (this *Server) WithWhiteService(serviceName string) *Server

+ type ServerConfig struct

+ func (this *ServerConfig) Address() string

+ func (this *ServerConfig) DeadLineTime() time.Duration

+ func (this *ServerConfig) IsWebSocket() bool

+ func (this *ServerConfig) MaxConnections() int32

+ func (this *ServerConfig) Port() string

+ func (this *ServerConfig) ReadBufferSize() int

+ func (this *ServerConfig) SetUserHook(userHook IUserHook)

+ func (this *ServerConfig) UserHook() IUserHook

+ func (this *ServerConfig) WithBuffer(readBuffer, writeBuffer int) ITCPBuilder

+ func (this *ServerConfig) WithPort(port string) ITCPBuilder

+ func (this *ServerConfig) WithWSPath(path string) ITCPBuilder

+ func (this *ServerConfig) WriteBufferSize() int

+ func (this *ServerConfig) WsPath() string

+ type ServiceAPI struct

+ Des string

+ MessageType string

+ ModuleName string

+ Name string

+ func (this *ServiceAPI[Req, Res]) GetResult() Res

+ func (this *ServiceAPI[Req, Res]) New(req Req, res Res) *ServiceAPI[Req, Res]

+ func (this *ServiceAPI[Req, Res]) NewEmpty() *ServiceAPI[Req, Res]

+ type TCPServer struct

+ func (this *TCPServer) DoLogin(userId, templateUserId string) (err error)

+ func (this *TCPServer) Offline(userId string, replace bool) (exists bool)

+ func (this *TCPServer) Run()

+ func (this *TCPServer) SetUserHook(userHook IUserHook)

+ func (this *TCPServer) ToUser(userId, messageType string, data []byte)

+ func (this *TCPServer) Update()

+ func (this *TCPServer) UpdateUserNodeInfo(userId, servicePath, nodeId string) bool

+ type ToUserReq struct

+ Data []byte

+ MessageType string

+ UserId string

+ type ToUserRes struct

+ ErrorCode int32

+ type UploadUserNodeInfoReq struct

+ NodeId string

+ ServicePath string

+ UserId string

+ type UploadUserNodeInfoRes struct

+ ErrorCode int32

+ type UserConnectData struct

+ func (this *UserConnectData) GetChannel() chan *client.Call

+ func (this *UserConnectData) GetContextData() *share.Context

+ func (this *UserConnectData) IsLogin() bool

+ func (this *UserConnectData) Login(userId string)

+ func (this *UserConnectData) Offline(userHook IUserHook)

+ func (this *UserConnectData) Send(data []byte)

+ func (this *UserConnectData) Stop()

+ func (this *UserConnectData) UpdateUserNodeId(servicePath, nodeId string)

+ type UserHook struct

+ func (u *UserHook) AddLoginHook(hook *ServiceAPI[*DefaultArgs, *EmptyReply]) IUserHook

+ func (u *UserHook) AddOfflineHook(hook *ServiceAPI[*DefaultArgs, *EmptyReply]) IUserHook

+ func (u *UserHook) GetLoginHooks() []*ServiceAPI[*DefaultArgs, *EmptyReply]

+ func (u *UserHook) GetOfflineHooks() []*ServiceAPI[*DefaultArgs, *EmptyReply]

+ type WSMessage struct

+ Data []byte

+ Module string

+ ReqId int32

+ ServiceName string

+ func (*WSMessage) Descriptor() ([]byte, []int)

+ func (*WSMessage) ProtoMessage()

+ func (x *WSMessage) GetData() []byte

+ func (x *WSMessage) GetModule() string

+ func (x *WSMessage) GetReqId() int32

+ func (x *WSMessage) GetServiceName() string

+ func (x *WSMessage) ProtoReflect() protoreflect.Message

+ func (x *WSMessage) Reset()

+ func (x *WSMessage) String() string

+ type WSResponse struct

+ Code int32

+ Data []byte

+ MessageType string

+ ReqId int32

+ func (*WSResponse) Descriptor() ([]byte, []int)

+ func (*WSResponse) ProtoMessage()

+ func (x *WSResponse) GetCode() int32

+ func (x *WSResponse) GetData() []byte

+ func (x *WSResponse) GetMessageType() string

+ func (x *WSResponse) GetReqId() int32

+ func (x *WSResponse) ProtoReflect() protoreflect.Message

+ func (x *WSResponse) Reset()

+ func (x *WSResponse) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL