microservice

type ConfigCenter interface {
	// Get 获取配置
	Get(key string) (string, error)

	// Set 设置配置
	Set(key, value string) error

	// Watch 监听配置变化
	Watch(key string) (<-chan string, error)

	// Delete 删除配置
	Delete(key string) error
}

type LoadBalancer interface {
	Select(instances []*ServiceInstance) *ServiceInstance
}

type MemoryConfigCenter struct {
	// contains filtered or unexported fields
}

type MemoryRegistry struct {
	// contains filtered or unexported fields
}

type RandomBalancer struct{}

type Registry interface {
	// Register 注册服务
	Register(instance *ServiceInstance) error

	// Deregister 注销服务
	Deregister(instanceID string) error

	// Discover 发现服务
	Discover(serviceName string) ([]*ServiceInstance, error)

	// Watch 监听服务变化
	Watch(serviceName string) (<-chan []*ServiceInstance, error)

	// Heartbeat 心跳
	Heartbeat(instanceID string) error
}

type RoundRobinBalancer struct {
	// contains filtered or unexported fields
}

type ServiceClient struct {
	// contains filtered or unexported fields
}

type ServiceInstance struct {
	ID       string            `json:"id"`
	Name     string            `json:"name"`
	Address  string            `json:"address"`
	Port     int               `json:"port"`
	Metadata map[string]string `json:"metadata"`
	Health   string            `json:"health"` // healthy, unhealthy
	Updated  time.Time         `json:"updated"`
}