selector

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

type HeartbeatOptions struct {
	Host                           string `yaml:"host"`
	Port                           string `yaml:"port"`
	Timeout                        string `yaml:"timeout"`
	Interval                       string `yaml:"interval"`
	DeregisterCriticalServiceAfter string `yaml:"deregister-critical-service-after"`
}

type Node struct {
	// Key   键: 服务名.
	Key string
	// Value 值: 结点ip地址.
	Value string
	// Blacklist 黑名单.
	Blacklist string
	// Whitelist 白名单.
	Whitelist string
	// Weight 权重.
	Weight float64
	// LastTime 最新更新时间.
	LastTime time.Duration
}

type Options struct {
	SelectorName      string `yaml:"name"`
	Address           string `yaml:"address"`
	Scheme            string `yaml:"scheme"`
	EnableHeartbeat   bool   `yaml:"enable-heartbeat"`
	*HeartbeatOptions `yaml:"heartbeat"`
}

type Selector interface {
	RegisterClient(name, address string) error
	RegisterService(name, address string) error
	RegisterHeartbeat()
	Select(string) (*ServiceNodes, error)
	LoadConfig(*Options) error
}

type ServiceNodes struct {
	// Name 服务名.
	Name string
	// Nodes 服务结点.
	Nodes []*Node
	// 结点数.
	Length int
	// LastTime 服务最后更新时间.
	LastTime time.Duration
	// contains filtered or unexported fields
}