registry

type Endpoint struct {
	Name     string            `json:"name"`
	Request  *Value            `json:"request"`
	Response *Value            `json:"response"`
	Metadata map[string]string `json:"metadata"`
}

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

type Option func(*Options)

type Options struct {
	Addrs         []string
	Timeout       time.Duration
	Secure        bool
	TLSConfig     *tls.Config
	Context       context.Context
	GroupID       int
	RedisHost     string
	RedisPassword string
}

type RedisService struct {
	Name    string // service name
	Address string // service address
}

type RegisterOption func(*RegisterOptions)

type RegisterOptions struct {
	TTL     time.Duration
	Context context.Context
}

type Registry interface {
	Options() Options
	Register(*Service, ...RegisterOption) error
	Deregister(*Service) error
	GetService(string) ([]*Service, error)
	ListServices() ([]*Service, error)
	String() string
	Clean(typeName string) error
}

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"`
	ID        string            `json:"id"`
	Address   string            `json:"address"`
}

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

type WatchOption func(*WatchOptions)

type WatchOptions struct {
	Service string
	Context context.Context
}

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