registry

type AppMeta struct {
	IP       string `json:"ip"`
	Port     int    `json:"port"`
	Weight   int    `json:"weight"`
	MetaData string `json:"meta_data"`
}

type EtcdConf struct {
	Endpoints         []string      `yaml:"endpoints"`
	DialTimeout       time.Duration `yaml:"dial_timeout"`
	DialKeepAliveTime time.Duration `yaml:"dial_keepalive_time"`
	LeaseTTL          int64         `yaml:"lease_ttl"`
}

type EtcdRegistryCenter struct {
	ErrC chan error
	// contains filtered or unexported fields
}

type RegisterCenter interface {
	Register(name string, meta *AppMeta) error
	UnRegister(name string) error
	GetServices(name string) ([]AppMeta, error)
}

type RegistryConf struct {
	Etcd *EtcdConf `yaml:"etcd"`
}