discovery

Documentation

Index

• func NewEdsSyncer(disc *EndpointDiscovery, discOpts Opts, refreshRate time.Duration) v1.EdsSyncer
• type DiscoveryPlugin
• type EndpointDiscovery
  • func NewEndpointDiscovery(watchNamespaces []string, writeNamespace string, ...) *EndpointDiscovery
  • func (d *EndpointDiscovery) Ready() <-chan struct{}
  • func (d *EndpointDiscovery) StartEds(upstreamsToTrack v1.UpstreamList, opts clients.WatchOpts) (chan error, error)
• type Opts
• type UpstreamDiscovery
  • func NewUpstreamDiscovery(watchNamespaces []string, writeNamespace string, ...) *UpstreamDiscovery
  • func (d *UpstreamDiscovery) Resync(ctx context.Context) error
  • func (d *UpstreamDiscovery) StartUds(opts clients.WatchOpts, discOpts Opts) (chan error, error)

Functions

func NewEdsSyncer

func NewEdsSyncer(disc *EndpointDiscovery, discOpts Opts, refreshRate time.Duration) v1.EdsSyncer

Types

type DiscoveryPlugin

type DiscoveryPlugin interface {
	plugins.Plugin

	// UDS API
	// send us an updated list of upstreams on every change
	// namespace is for writing to, not necessarily reading from
	DiscoverUpstreams(watchNamespaces []string, writeNamespace string, opts clients.WatchOpts, discOpts Opts) (chan v1.UpstreamList, chan error, error)
	// finalize any changes to the desired upstream before it gets written
	// for example, copying the functions from the old upstream to the new.
	// a value of false indicates that the resource does not need to be updated
	UpdateUpstream(original, desired *v1.Upstream) (bool, error)

	// EDS API
	// start the EDS watch which sends a new list of endpoints on any change
	// will send only endpoints for upstreams configured with TrackUpstreams
	WatchEndpoints(writeNamespace string, upstreamsToTrack v1.UpstreamList, opts clients.WatchOpts) (<-chan v1.EndpointList, <-chan error, error)
}

type EndpointDiscovery

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

func NewEndpointDiscovery

func NewEndpointDiscovery(
	watchNamespaces []string,
	writeNamespace string,
	endpointsClient v1.EndpointClient,
	statusSetter resources.StatusSetter,
	discoveryPlugins []DiscoveryPlugin) *EndpointDiscovery

func (*EndpointDiscovery) Ready

func (d *EndpointDiscovery) Ready() <-chan struct{}

func (*EndpointDiscovery) StartEds

func (d *EndpointDiscovery) StartEds(upstreamsToTrack v1.UpstreamList, opts clients.WatchOpts) (chan error, error)

launch a goroutine for all the EDS plugins with a single cancel to close them all

type Opts

type Opts struct {
	KubeOpts struct {
		IgnoredServices []string
	}
}

type UpstreamDiscovery

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

func NewUpstreamDiscovery

func NewUpstreamDiscovery(
	watchNamespaces []string,
	writeNamespace string,
	upstreamClient v1.UpstreamClient,
	statusSetter resources.StatusSetter,
	discoveryPlugins []DiscoveryPlugin) *UpstreamDiscovery

func (*UpstreamDiscovery) Resync

func (d *UpstreamDiscovery) Resync(ctx context.Context) error

ensures that the latest desired upstreams are in sync

func (*UpstreamDiscovery) StartUds

func (d *UpstreamDiscovery) StartUds(opts clients.WatchOpts, discOpts Opts) (chan error, error)

launch a goroutine for all the UDS plugins