serverconnector

type EventHandler interface {
	// OnServiceUpdate 回调函数接口
	// 返回缓存值是否已经被清理(对于服务被剔除，或者首次服务拉取失败，会返回true)
	OnServiceUpdate(*ServiceEvent)
	// GetRevision 获取缓存版本号
	GetRevision() string
	// GetBusiness 获取业务
	GetBusiness() string
}

type MessageCallBack interface {
	// OnResponse 收到应答后回调
	OnResponse(proto.Message)
}

type Proxy struct {
	ServerConnector
	// contains filtered or unexported fields
}

type ServerConnector interface {
	plugin.Plugin
	// RegisterServiceHandler 注册服务监听器
	// 异常场景：当key不合法或者sdk已经退出过程中，则返回error
	RegisterServiceHandler(*ServiceEventHandler) error
	// DeRegisterServiceHandler 反注册事件监听器
	// 异常场景：当sdk已经退出过程中，则返回error
	DeRegisterServiceHandler(*model.ServiceEventKey) error
	// RegisterInstance 同步注册服务
	RegisterInstance(req *model.InstanceRegisterRequest, header map[string]string) (*model.InstanceRegisterResponse, error)
	// DeregisterInstance 同步反注册服务
	DeregisterInstance(instance *model.InstanceDeRegisterRequest) error
	// Heartbeat 心跳上报
	Heartbeat(instance *model.InstanceHeartbeatRequest) error
	// ReportClient 上报客户端信息
	// 异常场景：当sdk已经退出过程中，则返回error
	// 异常场景：当服务端不可用或者上报失败，则返回error，调用者需进行重试
	ReportClient(*model.ReportClientRequest) (*model.ReportClientResponse, error)
	// UpdateServers 更新服务端地址
	// 异常场景：当地址列表为空，或者地址全部连接失败，则返回error，调用者需进行重试
	UpdateServers(key *model.ServiceEventKey) error
}

type ServiceEvent struct {
	// 服务
	model.ServiceEventKey
	// 事件对象值
	Value proto.Message
	// 服务错误
	Error model.SDKError
}

type ServiceEventHandler struct {
	*model.ServiceEventKey
	// 目标发现集群，对于系统服务，需要使用默认集群来进行发现
	TargetCluster config.ClusterType
	// 服务的定期刷新时间，默认1s
	RefreshInterval time.Duration
	// 服务事件处理句柄
	Handler EventHandler
}