Versions in this module Expand all Collapse all v2 v2.1.4 Mar 15, 2023 Changes in this version + type ClientDetectionRequestHandler struct + func (c *ClientDetectionRequestHandler) Name() string + func (c *ClientDetectionRequestHandler) RequestReply(request rpc_request.IRequest, rpcClient *RpcClient) rpc_response.IResponse + type ConnectResetRequestHandler struct + func (c *ConnectResetRequestHandler) Name() string + func (c *ConnectResetRequestHandler) RequestReply(request rpc_request.IRequest, rpcClient *RpcClient) rpc_response.IResponse + type Connection struct + type ConnectionEvent struct + type ConnectionStatus uint32 + const CONNECTED + const DISCONNECTED + type ConnectionType uint32 + const GRPC + type GrpcClient struct + func NewGrpcClient(ctx context.Context, clientName string, nacosServer *nacos_server.NacosServer) *GrpcClient + type GrpcConnection struct + func NewGrpcConnection(serverInfo ServerInfo, connectionId string, conn *grpc.ClientConn, ...) *GrpcConnection + type IConnection interface + type IConnectionEventListener interface + OnConnected func() + OnDisConnect func() + type IRpcClient interface + GetRpcClient func() *RpcClient + func CreateClient(ctx context.Context, clientName string, connectionType ConnectionType, ...) (IRpcClient, error) + type IServerRequestHandler interface + Name func() string + RequestReply func(request rpc_request.IRequest, rpcClient *RpcClient) rpc_response.IResponse + type NamingPushRequestHandler struct + ServiceInfoHolder *naming_cache.ServiceInfoHolder + func (*NamingPushRequestHandler) Name() string + func (c *NamingPushRequestHandler) RequestReply(request rpc_request.IRequest, rpcClient *RpcClient) rpc_response.IResponse + type ReconnectContext struct + type RpcClient struct + Tenant string + func (r *RpcClient) GetRpcClient() *RpcClient + func (r *RpcClient) IsInitialized() bool + func (r *RpcClient) IsRunning() bool + func (r *RpcClient) Name() string + func (r *RpcClient) RegisterConnectionListener(listener IConnectionEventListener) + func (r *RpcClient) RegisterServerRequestHandler(request func() rpc_request.IRequest, handler IServerRequestHandler) + func (r *RpcClient) Request(request rpc_request.IRequest, timeoutMills int64) (rpc_response.IResponse, error) + func (r *RpcClient) Shutdown() + func (r *RpcClient) Start() + type RpcClientStatus int32 + const INITIALIZED + const RUNNING + const SHUTDOWN + const STARTING + const UNHEALTHY + type ServerInfo struct + type ServerRequestHandlerMapping struct
Go to main page