cluster

package

Go to main page

Versions in this module

v2

v2.0.6

May 11, 2024

Changes in this version

+ func GetNodeByTemplateServiceName(templateServiceName string) map[string]string

+ func GetNodeIdByTemplateService(templateServiceName string, rpcClientList []*rpc.Client, filterRetire bool) (error, []*rpc.Client)

type Cluster

+ func (cls *Cluster) GetNodeIdByTemplateService(templateServiceName string, rpcClientList []*rpc.Client, filterRetire bool) (error, []*rpc.Client)

v2.0.5

May 8, 2024

v2.0.4

Apr 30, 2024

v2.0.3

Apr 30, 2024

v2.0.2

Apr 28, 2024

v2.0.1

Apr 26, 2024

Changes in this version

+ const EtcdType

+ const InvalidType

+ const MinTTL

+ const OriginDiscoveryClientName

+ const OriginDiscoveryMasterName

+ const OriginType

+ const RpcPingMethod

+ const UnRegServiceDiscover

type Cluster

+ func (cls *Cluster) AddDiscoveryService(serviceName string, bPublicService bool)

+ func (cls *Cluster) GetEtcdDiscovery() *EtcdDiscovery

+ func (cls *Cluster) GetNatsUrl() string

+ func (cls *Cluster) GetOriginDiscovery() *OriginDiscovery

+ func (cls *Cluster) IsNatsMode() bool

+ func (cls *Cluster) IsOriginMasterDiscoveryNode(nodeId string) bool

+ func (cls *Cluster) NotifyAllService(event event.IEvent)

+ func (cls *Cluster) SetRpcMode(cfgRpcMode *RpcMode, rpcMode *RpcMode) error

+ func (dc *Cluster) CanDiscoveryService(fromMasterNodeId string, serviceName string) bool

+ type DiscoveryInfo struct

+ Etcd *EtcdDiscovery

+ Origin *OriginDiscovery

+ type DiscoveryService struct

+ MasterNodeId string

+ NetworkName string

+ ServiceList []string

+ type DiscoveryType int

+ type EtcdDiscovery struct

+ DialTimeoutMillisecond time.Duration

+ EtcdList []EtcdList

+ TTLSecond int64

+ type EtcdDiscoveryService struct

+ func (ed *EtcdDiscoveryService) InitDiscovery(localNodeId string, funDelNode FunDelNode, funSetNode FunSetNode) error

+ func (ed *EtcdDiscoveryService) OnEtcdDiscovery(ev event.IEvent)

+ func (ed *EtcdDiscoveryService) OnEventDelete(watchKey string, Kv *mvccpb.KeyValue)

+ func (ed *EtcdDiscoveryService) OnEventGets(watchKey string, Kvs []*mvccpb.KeyValue)

+ func (ed *EtcdDiscoveryService) OnEventPut(watchKey string, Kv *mvccpb.KeyValue)

+ func (ed *EtcdDiscoveryService) OnInit() error

+ func (ed *EtcdDiscoveryService) OnNodeDisconnect(nodeId string)

+ func (ed *EtcdDiscoveryService) OnRelease()

+ func (ed *EtcdDiscoveryService) OnRetire()

+ func (ed *EtcdDiscoveryService) RPC_ServiceRecord(etcdServiceRecord *service.EtcdServiceRecordEvent, empty *service.Empty) error

+ func (nd *EtcdDiscoveryService) OnStart()

+ type EtcdList struct

+ Endpoints []string

+ NetworkName []string

+ type FunSetNode func(nodeInfo *NodeInfo)

+ type NatsConfig struct

+ NatsUrl string

+ NoRandomize bool

type NodeInfo

+ DiscoveryService []DiscoveryService

+ NetworkName string

type NodeInfoList

+ Discovery DiscoveryInfo

+ RpcMode RpcMode

+ type OriginDiscovery struct

+ MasterNodeList []NodeInfo

+ TTLSecond int64

+ type OriginDiscoveryClient struct

+ func (dc *OriginDiscoveryClient) InitDiscovery(localNodeId string, funDelNode FunDelNode, funSetNode FunSetNode) error

+ func (dc *OriginDiscoveryClient) OnInit() error

+ func (dc *OriginDiscoveryClient) OnNatsConnected()

+ func (dc *OriginDiscoveryClient) OnNatsDisconnect()

+ func (dc *OriginDiscoveryClient) OnNodeConnected(nodeId string)

+ func (dc *OriginDiscoveryClient) OnNodeDisconnect(nodeId string)

+ func (dc *OriginDiscoveryClient) OnRelease()

+ func (dc *OriginDiscoveryClient) OnRetire()

+ func (dc *OriginDiscoveryClient) OnStart()

+ func (dc *OriginDiscoveryClient) RPC_SubServiceDiscover(req *rpc.SubscribeDiscoverNotify) error

+ type OriginDiscoveryMaster struct

+ func (dc *OriginDiscoveryMaster) OnNatsConnected()

+ func (dc *OriginDiscoveryMaster) OnNatsDisconnect()

+ func (ds *OriginDiscoveryMaster) OnInit() error

+ func (ds *OriginDiscoveryMaster) OnNodeConnected(nodeId string)

+ func (ds *OriginDiscoveryMaster) OnNodeDisconnect(nodeId string)

+ func (ds *OriginDiscoveryMaster) OnStart()

+ func (ds *OriginDiscoveryMaster) RPC_NodeRetire(req *rpc.NodeRetireReq, res *rpc.Empty) error

+ func (ds *OriginDiscoveryMaster) RPC_Ping(req *rpc.Ping, res *rpc.Pong) error

+ func (ds *OriginDiscoveryMaster) RPC_RegServiceDiscover(req *rpc.RegServiceDiscoverReq, res *rpc.SubscribeDiscoverNotify) error

+ func (ds *OriginDiscoveryMaster) RPC_UnRegServiceDiscover(req *rpc.UnRegServiceDiscoverReq, res *rpc.Empty) error

+ func (ds *OriginDiscoveryMaster) RpcCastGo(serviceMethod string, args interface{})

+ type RpcMode struct

+ Nats NatsConfig

+ Typ string

v2.0.0

Apr 9, 2024

Changes in this version

+ const AddSubServiceDiscover

+ const DynamicDiscoveryClientName

+ const DynamicDiscoveryMasterName

+ const NodeRetireRpcMethod

+ const RegServiceDiscover

+ const SubServiceDiscover

+ func GetNodeByServiceName(serviceName string) map[int]struct

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

+ func GetRpcServer() *rpc.Server

+ func HasService(nodeId int, serviceName string) bool

+ func SetConfigDir(cfgDir string)

+ func SetServiceDiscovery(serviceDiscovery IServiceDiscovery)

+ type Cluster struct

+ func GetCluster() *Cluster

+ func (cls *Cluster) AddDynamicDiscoveryService(serviceName string, bPublicService bool)

+ func (cls *Cluster) DelNode(nodeId int, immediately bool)

+ func (cls *Cluster) DiscardNode(nodeId int)

+ func (cls *Cluster) FindRpcHandler(serviceName string) rpc.IRpcHandler

+ func (cls *Cluster) GetDiscoveryNodeList() []NodeInfo

+ func (cls *Cluster) GetGlobalCfg() interface{}

+ func (cls *Cluster) GetLocalNodeInfo() *NodeInfo

+ func (cls *Cluster) GetMasterDiscoveryNodeInfo(nodeId int) *NodeInfo

+ func (cls *Cluster) GetNodeIdByService(serviceName string, rpcClientList []*rpc.Client, filterRetire bool) (error, int)

+ func (cls *Cluster) GetNodeInfo(nodeId int) (NodeInfo, bool)

+ func (cls *Cluster) GetRpcClient(nodeId int) (*rpc.Client, bool)

+ func (cls *Cluster) GetServiceCfg(serviceName string) interface{}

+ func (cls *Cluster) Init(localNodeId int, setupServiceFun SetupServiceFun) error

+ func (cls *Cluster) InitCfg(localNodeId int) error

+ func (cls *Cluster) IsConfigService(serviceName string) bool

+ func (cls *Cluster) IsMasterDiscoveryNode() bool

+ func (cls *Cluster) IsNodeConnected(nodeId int) bool

+ func (cls *Cluster) IsNodeRetire(nodeId int) bool

+ func (cls *Cluster) ReadClusterConfig(filepath string) (*NodeInfoList, error)

+ func (cls *Cluster) RegDiscoveryEvent(serviceName string)

+ func (cls *Cluster) RegRpcEvent(serviceName string)

+ func (cls *Cluster) SetupServiceDiscovery(localNodeId int, setupServiceFun SetupServiceFun)

+ func (cls *Cluster) Start()

+ func (cls *Cluster) Stop()

+ func (cls *Cluster) TriggerDiscoveryEvent(bDiscovery bool, nodeId int, serviceName []string)

+ func (cls *Cluster) UnReDiscoveryEvent(serviceName string)

+ func (cls *Cluster) UnRegRpcEvent(serviceName string)

+ type ConfigDiscovery struct

+ func (discovery *ConfigDiscovery) InitDiscovery(localNodeId int, funDelNode FunDelNode, funSetNodeInfo FunSetNodeInfo) error

+ func (discovery *ConfigDiscovery) OnNodeStop()

+ type DynamicDiscoveryClient struct

+ func (dc *DynamicDiscoveryClient) InitDiscovery(localNodeId int, funDelNode FunDelNode, funSetNodeInfo FunSetNodeInfo) error

+ func (dc *DynamicDiscoveryClient) OnInit() error

+ func (dc *DynamicDiscoveryClient) OnNodeConnected(nodeId int)

+ func (dc *DynamicDiscoveryClient) OnNodeDisconnect(nodeId int)

+ func (dc *DynamicDiscoveryClient) OnNodeStop()

+ func (dc *DynamicDiscoveryClient) OnRetire()

+ func (dc *DynamicDiscoveryClient) OnStart()

+ func (dc *DynamicDiscoveryClient) RPC_SubServiceDiscover(req *rpc.SubscribeDiscoverNotify) error

+ type DynamicDiscoveryMaster struct

+ func (ds *DynamicDiscoveryMaster) OnInit() error

+ func (ds *DynamicDiscoveryMaster) OnNodeConnected(nodeId int)

+ func (ds *DynamicDiscoveryMaster) OnNodeDisconnect(nodeId int)

+ func (ds *DynamicDiscoveryMaster) OnStart()

+ func (ds *DynamicDiscoveryMaster) RPC_NodeRetire(req *rpc.NodeRetireReq, res *rpc.Empty) error

+ func (ds *DynamicDiscoveryMaster) RPC_RegServiceDiscover(req *rpc.ServiceDiscoverReq, res *rpc.Empty) error

+ func (ds *DynamicDiscoveryMaster) RpcCastGo(serviceMethod string, args interface{})

+ type FunDelNode func(nodeId int, immediately bool)

+ type FunSetNodeInfo func(nodeInfo *NodeInfo)

+ type IServiceDiscovery interface

+ InitDiscovery func(localNodeId int, funDelNode FunDelNode, funSetNodeInfo FunSetNodeInfo) error

+ OnNodeStop func()

+ type MasterDiscoveryService struct

+ DiscoveryService []string

+ MasterNodeId int32

+ type NodeInfo struct

+ CompressBytesLen int

+ ListenAddr string

+ MasterDiscoveryService []MasterDiscoveryService

+ MaxRpcParamLen uint32

+ NodeId int

+ NodeName string

+ Private bool

+ PublicServiceList []string

+ Retire bool

+ ServiceList []string

+ type NodeInfoList struct

+ MasterDiscoveryNode []NodeInfo

+ NodeList []NodeInfo

+ type NodeRpcInfo struct

+ type NodeStatus int

+ const Discard

+ const Normal

+ type OperType int

+ type SetupServiceFun func(s ...service.IService)

Other modules containing this package

github.com/duanhf2012/origin

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