package registry

import "errors"

//Registry 注册表为服务发现提供了一个接口,以及对不同实现的抽象{consul, etcd, zookeeper, ...}
type Registry interface {
	Init(...Option) error
	Options() Options
	Register(*Service, ...RegisterOption) error
	Deregister(*Service) error
	GetService(string) ([]*Service, error)
	ListServices() ([]*Service, error)
	Watch(...WatchOption) (Watcher, error)
	String() string

	//KV存储
	Put(key string, value interface{}) (err error)
	Get(key string) (rsp *KVResult, err error)
	Delete(key string) (err error)
	BlockingQuery(targetPointer interface{}, prefix interface{}, call func(value interface{}))
}
type Option func(*Options)
type RegisterOption func(*RegisterOptions)
type WatchOption func(*WatchOptions)

var (
	// ErrNotFound ErrNotFound
	ErrNotFound = errors.New("not found")
)