endpointer

type DefaultEndpointer ¶

type DefaultEndpointer struct {
	// contains filtered or unexported fields
}

func (de *DefaultEndpointer) Close() error

func (de *DefaultEndpointer) Endpoints() ([]endpoint.Endpoint, error)

type Endpointer ¶

type Endpointer interface {
	io.Closer
	Endpoints() ([]endpoint.Endpoint, error)
}

Endpointer resolves a set of live Endpoints from a service-discovery source. It subscribes to an Instancer and keeps an EndpointCache up to date. Close must be called to stop the background goroutine and release resources.

func NewEndpointer(src interfaces.Instancer, f endpoint.Factory, logger *log.Logger, options ...endpoint.EndpointerOption) Endpointer