registry

type Discovery interface {
	// GetService 根据 RPC 方法名返回可用节点和所属 appId。
	// 例如方法 /user.UserService/Login 会映射到一个 appId 及其节点列表。
	GetService(method string) ([]*ServiceNode, string, error)

	// Watcher 启动发现监听并持续维护本地索引。
	// 该方法通常阻塞运行，内部负责同步 Method -> AppId 与 AppId -> Nodes 的映射关系。
	Watcher()
	// Unwatch 停止监听并释放内部资源。
	Unwatch()

	// WatchEvent 注册变更回调，供外部订阅服务增删改事件。
	// 回调触发时机由具体实现决定，调用方不应阻塞回调执行。
	WatchEvent(callback WatchEventFunc)
}

type EventType int

type GatewayConf struct {
	// 网卡
	Network *Network `json:"network"`
}

type Kernel struct {
	// 所使用的开发语言
	Language string `json:"language"`
	// 内核版本
	Version string `json:"version"`
}

type Meta struct {
	// 环境，不同环境的服务不互通
	Env string `json:"env"`
	// 服务实例版本
	Version string `json:"version"`
	// 实例id, 实例id和应用id的区别就是，一个服务主体可以有多个实例
	InstanceId string `json:"instance_id"`
	// 应用id，泛指服务主体，不同版本的服务实例可以共享appId
	AppId string `json:"app_id"`
}

type Network struct {
	// 网卡唯一标识，用于grpc-gateway流量控制，同sn流量优先
	SN string `json:"sn"`
	// 内网地址
	Internal string `json:"internal"`
	// 外网地址
	External string `json:"external"`
}

type Register interface {
	// Install 安装并注册一个服务节点，完成必要的元信息填充与持久化。
	Install(service *ServiceNode) error
	// Uninstall 注销当前注册的服务节点并释放相关资源。
	Uninstall() error
}

type ServiceConf struct {
	// 实例Id
	InstanceId string `json:"instance_id"`
	// 命名空间
	Namespace string `json:"namespace"`
	// 网卡
	Network *Network `json:"network"`
	// 内核
	Kernel *Kernel `json:"kernel"`

	// 最大重试次数, 间隔时间是TTL*5
	MaxRetry uint32 `json:"max_retry"`
	// 心跳/租约 TTL（秒）, 最少是10s
	TTL uint32 `json:"ttl"`
	// 权重
	Weight int `json:"weight"`
}

type ServiceDiscover map[string][]*ServiceNode

type ServiceEvent struct {
	Type    EventType
	Service *ServiceNode
}

type ServiceMethod map[string]string

type ServiceNode struct {
	ProtoCount int             `json:"proto_count"`
	Weight     int             `json:"weight"` // 权重，默认100
	RunDate    string          `json:"run_date"`
	Methods    map[string]bool `json:"methods"`

	Network *Network `json:"network"`
	Kernel  *Kernel  `json:"kernel"`
	Meta    *Meta    `json:"meta"`
}

type WatchEventFunc = func(event *ServiceEvent)