node

package
v1.0.0-bate1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 21, 2021 License: LGPL-3.0 Imports: 10 Imported by: 0

Documentation

Overview

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

Index

Constants

View Source
const RpcExecuteFuncName = "Execute"
View Source
const RpcServiceName = "ESNode"

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

Variables

This section is empty.

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 执行服务

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL