registry

type Config struct {
	config.Config `field:"-"`
	Name          string          `field:"-"` //
	PrefixName    string          `field:"-"` // config prefix name/path in config file
	Logger        logger.ILogger  `field:"-"` // 实例
	Context       context.Context `field:"-"`
	LocalServices []*Service      `field:"-"` // current service information
	Addrs         []string        `field:"-"`
	TlsConfig     *tls.Config     `field:"-"`

	Timeout time.Duration
	Secure  bool
	TTL     time.Duration `field:"ttl"`
}

type DeregisterConfig struct {
	Context context.Context
}

type Endpoint struct {
	// RPC Method e.g. Greeter.Hello
	Name string `json:"name"`
	// HTTP Host e.g example.com
	Host []string `json:"host"`
	// HTTP Methods e.g GET, POST
	Method []string `json:"method"`
	// HTTP Path e.g /greeter. Expect POSIX regex
	Path string `json:"path"`
	// Description e.g what's this endpoint for
	Description string `json:"description"`
	// Stream flag
	Stream bool `json:"stream"`

	// 以下待确认
	Request  *Value            `json:"request"`
	Response *Value            `json:"response"`
	Metadata map[string]string `json:"metadata"`

	// API Handler e.g rpc, proxy
	Handler string
	// Body destination
	// "*" or "" - top level message value
	// "string" - inner message value
	Body string
}

type Event struct {
	// Id is registry id
	Id string
	// Type defines type of event
	Type EventType
	// Timestamp is event timestamp
	Timestamp time.Time
	// Service is registry service
	Service *Service
}

type EventType int

type GetConfig struct {
	Context context.Context
}

type IRegistry interface {
	Init(...Option) error
	Config() *Config
	Register(*Service, ...Option) error   // 注册
	Deregister(*Service, ...Option) error // 注销
	GetService(string) ([]*Service, error)
	ListServices() ([]*Service, error)
	Watcher(...WatchOptions) (Watcher, error)
	LocalServices() []*Service
	String() string
}

type ListConfig struct {
	Context context.Context
}

type Node struct {
	Id       string            `json:"id"`
	Address  string            `json:"address"`
	Metadata map[string]string `json:"metadata"`
}

type Option func(*Config)

type RegisterConfig struct {
	TTL time.Duration
	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type Result struct {
	Action  string
	Service *Service
}

type Service struct {
	Name      string            `json:"name"`
	Version   string            `json:"version"`
	Metadata  map[string]string `json:"metadata"`
	Endpoints []*Endpoint       `json:"endpoints"`
	Nodes     []*Node           `json:"nodes"`
}

type Value struct {
	Name   string   `json:"name"`
	Type   string   `json:"type"`
	Values []*Value `json:"values"`
}

type WatchConfig struct {
	// Specify a service to watch
	// If blank, the watch is for all services
	Service string
	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type WatchOptions func(*WatchConfig) error

type Watcher interface {
	// Next is a blocking call
	Next() (*Result, error)
	Stop()
}