nexus

Documentation

Index

• func StartServer(port int, serviceInfos ...ServiceInfo) error
• type MethodInfo
• type RpcClient
  • func NewClient(address string, poolMaxNum int) *RpcClient
  • func (client *RpcClient) Invoke(args any, serviceName string, methodName string, reply any) error
  • func (client *RpcClient) SendReq(request *common.RpcRequest) (resp *common.RpcResponse, err error)
• type RpcServer
  • func (s *RpcServer) Registry(sr ServiceInfo)
• type ServiceInfo

Functions

func StartServer

func StartServer(port int, serviceInfos ...ServiceInfo) error

Types

type MethodInfo

type MethodInfo struct {
	Method   reflect.Method
	ParType  reflect.Type
	RelyType reflect.Type
}

type RpcClient

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

func NewClient

func NewClient(address string, poolMaxNum int) *RpcClient

func (*RpcClient) Invoke

func (client *RpcClient) Invoke(args any, serviceName string, methodName string, reply any) error

func (*RpcClient) SendReq

func (client *RpcClient) SendReq(request *common.RpcRequest) (resp *common.RpcResponse, err error)

type RpcServer

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

func (*RpcServer) Registry

func (s *RpcServer) Registry(sr ServiceInfo)

type ServiceInfo

type ServiceInfo struct {
	Name    string
	Value   reflect.Value
	Methods map[string]*MethodInfo
}