endpointdiscovery

Documentation

Index

• func Less(e1, e2 Endpoint) bool
• type Endpoint
• type EndpointGroups
• type Interface

Functions

func Less

func Less(e1, e2 Endpoint) bool

Types

type Endpoint

type Endpoint struct {
	Address string
	Port    int32
}

type EndpointGroups

type EndpointGroups map[string][]Endpoint

groups endpoints by their respective upstream name

type Interface

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
}