cluster

package

v0.0.0-...-a538cea Latest Latest Go to latest Published: Aug 31, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func GetRpcClient(nodeId int, serviceMethod string, clientList *[]*rpc.Client) error

func GetRpcServer() *rpc.Server

func SetConfigDir(cfgdir string)

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

func GetCluster() *Cluster

func (slf *Cluster) FindRpcHandler(servicename string) rpc.IRpcHandler

func (slf *Cluster) GetNodeIdByService(servicename string, rpcClientList *[]*rpc.Client)

func (slf *Cluster) GetRpcClient(nodeid int) *rpc.Client

func (slf *Cluster) GetServiceCfg(nodeid int, servicename string) interface{}

func (slf *Cluster) Init(currentNodeId int) error

func (slf *Cluster) InitCfg(currentNodeId int) error

func (slf *Cluster) IsConfigService(servicename string) bool

func (slf *Cluster) IsNodeConnected(nodeId int) bool

func (slf *Cluster) ReadAllSubNetConfig() error

func (slf *Cluster) ReadClusterConfig(filepath string) (*SubNet, error)

func (slf *Cluster) ReadLocalSubNetServiceConfig(subnet string) error

func (slf *Cluster) ReadServiceConfig(filepath string) (map[string]interface{}, map[int]map[string]interface{}, error)

func (slf *Cluster) Start()

type NodeInfo struct {
	NodeId      int
	ListenAddr  string
	NodeName    string
	ServiceList []string
}

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

type SubNet struct {
	SubNetName string
	NodeList   []NodeInfo
}