registry

type Discovery interface {
	// GetService 根据方法名返回可用节点列表。
	GetService(name string) ([]*ServiceNode, error)
	// Watcher 启动监听并持续刷新本地缓存。
	Watcher()
	// Unwatch 停止监听并释放相关资源。
	Unwatch()
}

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()
	// SustainLease 维持租约/心跳，发生异常时可结合重试策略恢复。
	SustainLease()
	// WithRetryBefore 设置重试前回调，用于指标/告警等场景。
	WithRetryBefore(func())
	// WithRetryAfter 设置重试成功后回调，用于恢复通知等场景。
	WithRetryAfter(func())
	// WithLog 设置内部日志回调，统一输出实现内部状态。
	WithLog(func(level logger.LogLevel, message string))
}

type ServiceConf struct {
	// 命名空间
	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"`
}

type ServiceDiscover map[string][]*ServiceNode

type ServiceMethod map[string]string

type ServiceNode struct {
	ProtoCount int             `json:"proto_count"`
	LeaseId    int             `json:"lease_id"`
	RunDate    string          `json:"run_date"`
	Methods    map[string]bool `json:"methods"`

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