rpc

Documentation

Index

• type ClientDetectionRequestHandler
  • func (c *ClientDetectionRequestHandler) Name() string
  • func (c *ClientDetectionRequestHandler) RequestReply(request rpc_request.IRequest, rpcClient *RpcClient) rpc_response.IResponse
• type ConnectResetRequestHandler
  • func (c *ConnectResetRequestHandler) Name() string
  • func (c *ConnectResetRequestHandler) RequestReply(request rpc_request.IRequest, rpcClient *RpcClient) rpc_response.IResponse
• type Connection
• type ConnectionEvent
• type ConnectionStatus
• type ConnectionType
• type GrpcClient
  • func NewGrpcClient(clientName string, xgrpcServer *xgrpc_server.XgrpcServer) *GrpcClient
• type GrpcConnection
  • func NewGrpcConnection(serverInfo ServerInfo, connectionId string, conn *grpc.ClientConn, ...) *GrpcConnection
• type IConnection
• type IConnectionEventListener
• type IRpcClient
  • func CreateClient(clientName string, connectionType ConnectionType, labels map[string]string, ...) (IRpcClient, error)
• type IServerRequestHandler
• type ReconnectContext
• type RpcClient
  • 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
• type ServerInfo
• type ServerRequestHandlerMapping

Types

type ClientDetectionRequestHandler

type ClientDetectionRequestHandler struct {
}

func (*ClientDetectionRequestHandler) Name

func (c *ClientDetectionRequestHandler) Name() string

func (*ClientDetectionRequestHandler) RequestReply

func (c *ClientDetectionRequestHandler) RequestReply(request rpc_request.IRequest, rpcClient *RpcClient) rpc_response.IResponse

type ConnectResetRequestHandler

type ConnectResetRequestHandler struct {
}

func (*ConnectResetRequestHandler) Name

func (c *ConnectResetRequestHandler) Name() string

func (*ConnectResetRequestHandler) RequestReply

func (c *ConnectResetRequestHandler) RequestReply(request rpc_request.IRequest, rpcClient *RpcClient) rpc_response.IResponse

type Connection

type Connection struct {
	// contains filtered or unexported fields
}

type ConnectionEvent

type ConnectionEvent struct {
	// contains filtered or unexported fields
}

type ConnectionStatus

type ConnectionStatus uint32

const (
	DISCONNECTED ConnectionStatus = iota
	CONNECTED
)

type ConnectionType

type ConnectionType uint32

const (
	GRPC ConnectionType = iota
)

type GrpcClient

type GrpcClient struct {
	*RpcClient
}

func NewGrpcClient

func NewGrpcClient(clientName string, xgrpcServer *xgrpc_server.XgrpcServer) *GrpcClient

type GrpcConnection

type GrpcConnection struct {
	*Connection
	// contains filtered or unexported fields
}

func NewGrpcConnection

func NewGrpcConnection(serverInfo ServerInfo, connectionId string, conn *grpc.ClientConn,
	client xgrpc_grpc_service.RequestClient, biStreamClient xgrpc_grpc_service.BiRequestStream_RequestBiStreamClient) *GrpcConnection

type IConnection

type IConnection interface {
	// contains filtered or unexported methods
}

type IConnectionEventListener

type IConnectionEventListener interface {

	//notify when  connected to server.
	OnConnected()

	//notify when  disconnected to server.
	OnDisConnect()
}

type IRpcClient

type IRpcClient interface {
	GetRpcClient() *RpcClient
	// contains filtered or unexported methods
}

func CreateClient

func CreateClient(clientName string, connectionType ConnectionType, labels map[string]string, xgrpcServer *xgrpc_server.XgrpcServer) (IRpcClient, error)

type IServerRequestHandler

type IServerRequestHandler interface {
	Name() string
	//RequestReply Handle request from server.
	RequestReply(request rpc_request.IRequest, rpcClient *RpcClient) rpc_response.IResponse
}

IServerRequestHandler to process the request from server side.

type ReconnectContext

type ReconnectContext struct {
	// contains filtered or unexported fields
}

type RpcClient

type RpcClient struct {
	Name string

	Tenant string
	// contains filtered or unexported fields
}

func (*RpcClient) GetRpcClient

func (r *RpcClient) GetRpcClient() *RpcClient

func (*RpcClient) IsInitialized

func (r *RpcClient) IsInitialized() bool

func (*RpcClient) IsRunning

func (r *RpcClient) IsRunning() bool

IsRunning check is this client is running.

func (*RpcClient) RegisterConnectionListener

func (r *RpcClient) RegisterConnectionListener(listener IConnectionEventListener)

func (*RpcClient) RegisterServerRequestHandler

func (r *RpcClient) RegisterServerRequestHandler(request func() rpc_request.IRequest, handler IServerRequestHandler)

func (*RpcClient) Request

func (r *RpcClient) Request(request rpc_request.IRequest, timeoutMills int64) (rpc_response.IResponse, error)

func (*RpcClient) Shutdown

func (r *RpcClient) Shutdown()

func (*RpcClient) Start

func (r *RpcClient) Start()

type RpcClientStatus

type RpcClientStatus int32

const (
	INITIALIZED RpcClientStatus = iota
	STARTING
	UNHEALTHY
	RUNNING
	SHUTDOWN
)

type ServerInfo

type ServerInfo struct {
	// contains filtered or unexported fields
}

type ServerRequestHandlerMapping

type ServerRequestHandlerMapping struct {
	// contains filtered or unexported fields
}