Versions in this module Expand all Collapse all v1 v1.0.4 Aug 8, 2022 Changes in this version + const RPC_REQUEST_TIMEOUT + var CHECK_ALIVE_INTERNAL = 100 + var MAX_CHECK_ALIVE_RETRY = 600 + type ClientMessageSender interface + SendMsgWithResponse func(msg interface{}) (interface{}, error) + SendMsgWithResponseAndTimeout func(msg interface{}, timeout time.Duration) (interface{}, error) + SendResponse func(request protocal.RpcMessage, serverAddress string, msg interface{}) + type GettyClientSessionManager struct + func (sessionManager *GettyClientSessionManager) AcquireGettySession() getty.Session + func (sessionManager *GettyClientSessionManager) AcquireGettySessionByServerAddress(serverAddress string) getty.Session + func (sessionManager *GettyClientSessionManager) RegisterGettySession(session getty.Session) + func (sessionManager *GettyClientSessionManager) ReleaseGettySession(session getty.Session) + type RpcRMMessage struct + RpcMessage protocal.RpcMessage + ServerAddress string + type RpcRemoteClient struct + BranchCommitRequestChannel chan RpcRMMessage + BranchRollbackRequestChannel chan RpcRMMessage + GettySessionOnOpenChannel chan string + func GetRpcRemoteClient() *RpcRemoteClient + func InitRpcRemoteClient() *RpcRemoteClient + func (client *RpcRemoteClient) OnClose(session getty.Session) + func (client *RpcRemoteClient) OnCron(session getty.Session) + func (client *RpcRemoteClient) OnError(session getty.Session, err error) + func (client *RpcRemoteClient) OnMessage(session getty.Session, pkg interface{}) + func (client *RpcRemoteClient) OnOpen(session getty.Session) error + func (client *RpcRemoteClient) RegisterResource(serverAddress string, request protocal.RegisterRMRequest) + func (client *RpcRemoteClient) SendMsgWithResponse(msg interface{}) (interface{}, error) + func (client *RpcRemoteClient) SendMsgWithResponseAndTimeout(msg interface{}, timeout time.Duration) (interface{}, error) + func (client *RpcRemoteClient) SendResponse(request protocal.RpcMessage, serverAddress string, msg interface{})
Go to main page