registry

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

type IListener interface {
	FindServiceHandlefunc(snode ServiceNode)
	UpDataServiceHandlefunc(snode ServiceNode)
	LoseServiceHandlefunc(sId string)
}

type ISys interface {
	Start() error
	Stop() error
	PushServiceInfo() (err error)
	GetServiceById(sId string) (n *ServiceNode, err error)
	GetServiceByType(sType string) (n []*ServiceNode)
	GetAllServices() (n []*ServiceNode)
	GetServiceByCategory(category core.S_Category) (n []*ServiceNode)
	GetRpcSubById(rId core.Rpc_Key) (n []*ServiceNode)
}

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

type Option func(*Options)

type Options struct {
	RegistryType            RegistryType
	Service                 base.IClusterService
	Listener                IListener
	Consul_Addr             string
	Consul_RegisterInterval int //定期注册
	Consul_RegisterTTL      int
	Nacos_NamespaceId       string
	Nacos_NacosAddr         string
	Nacos_Port              uint64
	Nacos_TimeoutMs         uint64 //连接超时 ms
	Nacos_BeatInterval      int64  //心跳间隔 ms
	Nacos_RegisterTTL       int
}

type RegistryType uint8

type ServiceNode struct {
	Tag          string          `json:"Tag"`          //服务集群标签
	Type         string          `json:"Type"`         //服务类型
	Category     core.S_Category `json:"Category"`     //服务列别
	Id           string          `json:"Id"`           //服务Id
	Version      string          `json:"Version"`      //服务版本
	IP           string          `json:"Ip"`           //服务Ip
	RpcId        string          `json:"RpcId"`        //服务通信Id
	PreWeight    float64         `json:"PreWeight"`    //服务负载权重
	RpcSubscribe []core.Rpc_Key  `json:"RpcSubscribe"` //服务开放接口
}