node

Documentation

Overview

Package node 文件包括本地服务（服务节点）的所有注册服务和远程调用本地服务的相应处理方法

Index

• Constants
• func GetLocalServiceIndex() map[string]*is.ServiceInfo
• func GetNodeConfig() *data.ESConfig
• func InitNodeServer(configFile ...string) error
• func Reg(serviceInstance interface{})
• func StartNodeServer()
• type ESNode
  • func (*ESNode) Execute(ctx context.Context, request *data.Request, result *data.Result) error

Constants

const RpcExecuteFuncName = "Execute"

const RpcServiceName = "ESNode"

RpcServiceName 节点执行服务的rpc服务名

Functions

func GetLocalServiceIndex

func GetLocalServiceIndex() map[string]*is.ServiceInfo

GetLocalServiceIndex 获取本地服务器的索引信息

func GetNodeConfig

func GetNodeConfig() *data.ESConfig

func InitNodeServer

func InitNodeServer(configFile ...string) error

InitNodeServer 初始化rpc服务端

func Reg

func Reg(serviceInstance interface{})

Reg 注册本地服务

func StartNodeServer

func StartNodeServer()

Types

type ESNode

type ESNode struct{}

ESNode rpcx暴露的服务

func (*ESNode) Execute

func (*ESNode) Execute(ctx context.Context, request *data.Request, result *data.Result) error

Execute 执行服务