registry

type Option func(*Options)

type Options struct {
	common.ApplicationConfig
	RegistryConfig

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type ProviderServiceConfig struct {
	ServiceConfig
	Path    string
	Methods string
}

type Registry interface {
	// Register(conf ServiceConfig) error
	Register(conf interface{}) error
	GetService(string) ([]*ServiceURL, error)
	ListServices() ([]*ServiceURL, error)
	Watch() (Watcher, error)
	Close()
	String() string
}

type RegistryConfig struct {
	Address  []string `required:"true"`
	UserName string
	Password string
	Timeout  int `default:"5"` // unit: second
}

type Result ServiceURLEvent

type ServerConfig struct {
	Protocol string `required:"true",default:"dubbo"` // codec string, jsonrpc etc
	IP       string
	Port     int `required:"true"`
}

type ServiceConfig struct {
	Protocol string `required:"true",default:"dubbo"` // codec string, jsonrpc etc
	// func (this *consumerZookeeperRegistry) Register(conf ServiceConfig) 函数用到了Service
	// "/dubbo/com.ofpay.demo.api.UserProvider/providers" Service指代中间这一部分，目前假设它与interface相同
	Service string `required:"true"`
	Group   string
	Version string
}

type ServiceConfigIf interface {
	String() string
	ServiceEqual(url *ServiceURL) bool
}

type ServiceURL struct {
	Protocol     string
	Location     string // ip+port
	Path         string // like  /com.qianmi.dubbo.UserProvider
	Ip           string
	Port         string
	Version      string
	Group        string
	Query        url.Values
	Weight       int32
	PrimitiveURL string
}

type ServiceURLEvent struct {
	Action  ServiceURLEventType
	Service *ServiceURL
}

type ServiceURLEventType int

type Watcher interface {
	// Next is a blocking call
	Next() (*Result, error)
	Valid() bool // 检查watcher与registry连接是否正常
	Stop()
}