endpointdiscovery

type Endpoint struct {
	Address string
	Port    int32
}

type EndpointGroups map[string][]Endpoint

type Interface interface {
	// starts the discovery service
	Run(stop <-chan struct{})

	// tells the discovery to track endpoints for the given upstreams
	TrackUpstreams(upstreams []*v1.Upstream)

	// endpoint groups are pushed here whenever they are updated
	Endpoints() <-chan EndpointGroups

	// should show valid if the most recent update passed, otherwise a useful error
	Error() <-chan error
}