gmicro

package module
v1.0.4 Latest Latest
Warning

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

 Go to latest Published: Mar 1, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

README

gmicro

一个使用zookeeper作为服务注册和发现，基于Actor模型的微服务框架。

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NodesChangeListener added in v1.0.1 

func NodesChangeListener(children []string, manager *NodesManager)

func SetLogger added in v1.0.4 

func SetLogger(logger *logrus.Logger)

Types

type Cluster 

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

func NewCluster added in v1.0.1 

func NewCluster(clustername, nodename, host string, port int, zkAddress []string) *Cluster

func NewSingleCluster added in v1.0.1 

func NewSingleCluster(clustername, nodename string) *Cluster

func (*Cluster) ActorOf added in v1.0.4 

func (cluster *Cluster) ActorOf(host string, port int, method string) actorsystem.ActorRef

func (*Cluster) BroadcastRoute added in v1.0.3 

func (cluster *Cluster) BroadcastRoute(method string, obj proto.Message, sender actorsystem.ActorRef)

func (*Cluster) BroadcastWithNoSender added in v1.0.1 

func (cluster *Cluster) BroadcastWithNoSender(method string, obj proto.Message)

func (*Cluster) CallbackActorOf added in v1.0.4 

func (cluster *Cluster) CallbackActorOf(ttl time.Duration, actor actorsystem.ICallbackUntypedActor) actorsystem.ActorRef

func (*Cluster) LocalActorOf added in v1.0.4 

func (cluster *Cluster) LocalActorOf(method string) actorsystem.ActorRef

func (*Cluster) RegisterActor added in v1.0.1 

func (cluster *Cluster) RegisterActor(method string, actorCreateFun func() actorsystem.IUntypedActor, concurrentCount int)

func (*Cluster) Shutdown added in v1.0.4 

func (cluster *Cluster) Shutdown()

func (*Cluster) Startup added in v1.0.4 

func (cluster *Cluster) Startup()

func (*Cluster) UnicastRoute added in v1.0.3 

func (cluster *Cluster) UnicastRoute(method, targetId string, obj proto.Message, sender actorsystem.ActorRef)

func (*Cluster) UnicastRouteWithNoSender added in v1.0.1 

func (cluster *Cluster) UnicastRouteWithNoSender(method, targetId string, obj proto.Message)

type IActorRegister added in v1.0.3 

type IActorRegister interface {
	RegisterActor(method string, actorCreateFun func() actorsystem.IUntypedActor, concurrentCount int)
}

type Node added in v1.0.1 

type Node struct {
	Name    string   `json:"name"`
	Ip      string   `json:"ip"`
	Port    int      `json:"port"`
	Methods []string `json:"methods"`
	// contains filtered or unexported fields
}

func NewNode added in v1.0.1 

func NewNode(name, ip string, port int) *Node

func (*Node) AddMethod added in v1.0.1 

func (node *Node) AddMethod(method string)

type NodesManager added in v1.0.1 

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

func NewNodesManager added in v1.0.1 

func NewNodesManager(basePath string, zkAddress []string) (*NodesManager, error)

func (*NodesManager) Destroy added in v1.0.1 

func (manager *NodesManager) Destroy()

* * destroy *

func (*NodesManager) GetTargetNode added in v1.0.1 

func (manager *NodesManager) GetTargetNode(method, targetId string) *Node

func (*NodesManager) RegisterSelf2ZK added in v1.0.1 

func (manager *NodesManager) RegisterSelf2ZK(node Node)

* * The path of node data: /gmicro/clusters/{clusterName}/nodes/{node.Name} * *

func (*NodesManager) WatchChildrensChange added in v1.0.1 

func (manager *NodesManager) WatchChildrensChange(path string, listener func(children []string, manager *NodesManager))

Source Files

View all Source files

Directories

Path Synopsis
rpc

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.