localregistry

type InstanceProperties struct {
	Service    *model.ServiceKey
	ID         string
	Properties map[string]interface{}
}

type InstancesFilter struct {
	Service           string
	Namespace         string
	IsInternalRequest bool
}

type InstancesRegistry interface {
	// GetInstances 非阻塞获取服务实例列表，只读取缓存
	GetInstances(svcKey *model.ServiceKey, includeCache bool, isInternalRequest bool) model.ServiceInstances
	// LoadInstances 非阻塞发起一次缓存远程加载操作
	// 如果已经加载过了，那就直接进行notify
	// 否则，加载完毕后调用notify函数
	LoadInstances(svcKey *model.ServiceKey) (*common.Notifier, error)
	// UpdateInstances 批量更新服务实例状态，properties存放的是状态值，当前支持2个key
	// 1. ReadyToServe: 故障熔断标识，true or false
	// 2. DynamicWeight：动态权重值
	UpdateInstances(*ServiceUpdateRequest) error
	// PersistMessage 对PB缓存进行持久化
	PersistMessage(file string, msg proto.Message) error
	// LoadPersistedMessage 从文件中加载PB缓存
	LoadPersistedMessage(file string, msg proto.Message) error
}

type LocalRegistry interface {
	plugin.Plugin
	InstancesRegistry
	RuleRegistry
}

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

type RuleFilter struct {
	model.ServiceEventKey
}

type RuleRegistry interface {
	// GetServiceRouteRule 非阻塞获取配置信息
	GetServiceRouteRule(key *model.ServiceKey, includeCache bool) model.ServiceRule
	// LoadServiceRouteRule 非阻塞发起配置加载
	LoadServiceRouteRule(key *model.ServiceKey) (*common.Notifier, error)
	// GetServiceRateLimitRule 非阻塞获取限流规则
	GetServiceRateLimitRule(key *model.ServiceKey, includeCache bool) model.ServiceRule
	// LoadServiceRateLimitRule 非阻塞发起限流规则加载
	LoadServiceRateLimitRule(key *model.ServiceKey) (*common.Notifier, error)
	// GetServicesByMeta 非阻塞获取批量服务
	GetServicesByMeta(key *model.ServiceKey, includeCache bool) model.Services
	// LoadServices 非阻塞加载批量服务
	LoadServices(key *model.ServiceKey) (*common.Notifier, error)
	// WatchService 添加服务监听标识
	WatchService(svcEventKey model.ServiceEventKey)
	// UnwatchService 取消服务监听标识
	UnwatchService(svcEventKey model.ServiceEventKey)
}

type ServiceUpdateRequest struct {
	model.ServiceKey
	Properties []InstanceProperties
}