registry

type Cfg struct {
	Driver string `json:"driver"`
}

type DeRegOpt func(*DeRegOpts)

type DeRegOpts struct {
	Context context.Context
}

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

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 Factory func(map[string]interface{}) (Registry, error)

type GetOpt func(*GetOpts)

type GetOpts struct {
	Timeout time.Duration
}

type ListOpt func(*ListOpts)

type ListOpts struct {
	Context context.Context
}

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

type Opt func(*Opts)

type Opts struct {
	Addrs     []string
	Timeout   time.Duration
	Secure    bool
	TLSConfig *tls.Config
	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type RegOpt func(*RegOpts)

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

type Registry interface {
	Register(*Service, ...RegOpt) error
	Deregister(*Service, ...DeRegOpt) error
	GetService(string, ...GetOpt) ([]*Service, error)
	ListServices(...ListOpt) ([]*Service, error)
	Watch(string, ...WatchOpt) (Watcher, error)
	String() string
}

type Result struct {
	Action  string
	Service *Service
}

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

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

type WatchOpt func(*WatchOpts)

type WatchOpts 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 Watcher interface {
	// Next is a blocking call
	Next() (*Result, error)
	Stop()
}