Versions in this module Expand all Collapse all v1 v1.99.1 Mar 16, 2022 Changes in this version + type ClientDetectionRequestHandler struct + func (c *ClientDetectionRequestHandler) RequestReply(request rpc_request.IRequest, rpcClient *RpcClient) rpc_response.IResponse + type ConnectResetRequestHandler struct + 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(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(clientName string, connectionType ConnectionType, labels map[string]string, ...) (IRpcClient, error) + type IServerRequestHandler interface + RequestReply func(request rpc_request.IRequest, rpcClient *RpcClient) rpc_response.IResponse + type NamingPushRequestHandler struct + ServiceInfoHolder *naming_cache.ServiceInfoHolder + func (c *NamingPushRequestHandler) RequestReply(request rpc_request.IRequest, rpcClient *RpcClient) rpc_response.IResponse + type ReconnectContext struct + type RpcClient struct + Name string + Tenant string + func (r *RpcClient) GetRpcClient() *RpcClient + func (r *RpcClient) IsInitialized() bool + func (r *RpcClient) IsRunning() bool + 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 Other modules containing this package github.com/EricLi404/nacos-sdk-go/v2
Go to main page