registry

type Discovery interface {
	// GetService 根据 rpc method (如 /user.UserService/Login) 返回可用节点列表和对应的 AppId。
	// 网关在接收到请求时，只有 method 信息，需要通过此方法路由到具体的微服务实例。
	GetService(method string) ([]*ServiceNode, string, error)

	// Watch 启动全量监听，返回变动事件的通道，通过 ctx 控制生命周期。
	// 监听实现需要维护内部的 Method -> AppId 以及 AppId -> ServiceNodes 映射。
	Watch(ctx context.Context) (<-chan ServiceEvent, error)
	// Unwatch 停止监听并释放相关资源。
	Unwatch()
}

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"`
	// 应用id，泛指服务实例，不同版本的服务实例可以共享appId
	AppId string `json:"app_id"`
	// 服务实例版本
	Version string `json:"version"`
}

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"`
}