registry

type Config interface {
	config.ConfigPlugin

	// Optional
	GetLogger() *log.ConfigImpl
	GetAddresses() []string

	// Timeout in milliseconds.
	GetTimeout() int
}

type ConfigImpl struct {
	*config.ConfigPluginImpl

	Logger    *log.ConfigImpl
	Addresses []string
	Timeout   int
}

type DeregisterOption func(*DeregisterOptions)

type DeregisterOptions struct {
	Context context.Context
}

type DiConfig struct{}

type DiFlags struct{}

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

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 GetOption func(*GetOptions)

type GetOptions struct {
	Context context.Context
}

type ListOption func(*ListOptions)

type ListOptions struct {
	Context context.Context
}

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

type Option func(*Options)

type Options struct {
	Logger log.Logger
}

type RegisterOption func(*RegisterOptions)

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

type Registry interface {
	Init(aConfig any, opts ...Option) error
	Config() any
	Register(*Service, ...RegisterOption) error
	Deregister(*Service, ...DeregisterOption) error
	GetService(string, ...GetOption) ([]*Service, error)
	ListServices(...ListOption) ([]*Service, error)
	Watch(...WatchOption) (Watcher, error)
	String() string
}

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 WatchOption func(*WatchOptions)

type WatchOptions 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()
}