registry

type DeregisterOption func(*DeregisterOptions)

type DeregisterOptions struct {
	Context context.Context
}

type GetOption func(*GetOptions)

type GetOptions struct {
	Context context.Context
}

type ListOption func(*ListOptions)

type ListOptions struct {
	Context context.Context
}

type OpenAPIOption func(*OpenAPIOptions)

type OpenAPIOptions struct {
	Context context.Context
}

type Option func(*Options)

type Options 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 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(...Option) error
	Options() Options
	Register(*regpb.Service, ...RegisterOption) error
	Deregister(*regpb.Service, ...DeregisterOption) error
	GetService(string, ...GetOption) ([]*regpb.Service, error)
	ListServices(...ListOption) ([]*regpb.Service, error)
	Watch(...WatchOption) (Watcher, error)
	String() string
}

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() (*regpb.Result, error)
	Stop()
}