registry

type NewRegistry func(...Option) 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
	GetServices(ServiceConfigIf) ([]*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
	Service  string `required:"true"`                 // 其本质是dubbo.xml中的interface
	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.ikurento.dubbo.UserProvider3
	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()
}