controller

Documentation

Overview

Package controller contains the router controller.

Index

• Variables
• func HostForRoute(route *routeapi.Route) string
• type ExtendedValidator
  • func NewExtendedValidator(plugin router.Plugin, recorder RejectionRecorder) *ExtendedValidator
  • func (p *ExtendedValidator) HandleEndpoints(eventType watch.EventType, endpoints *kapi.Endpoints) error
  • func (p *ExtendedValidator) HandleNamespaces(namespaces sets.String) error
  • func (p *ExtendedValidator) HandleNode(eventType watch.EventType, node *kapi.Node) error
  • func (p *ExtendedValidator) HandleRoute(eventType watch.EventType, route *routeapi.Route) error
  • func (p *ExtendedValidator) SetLastSyncProcessed(processed bool) error
• type HostAdmitter
  • func NewHostAdmitter(plugin router.Plugin, fn RouteAdmissionFunc, restrict bool, ...) *HostAdmitter
  • func (p *HostAdmitter) HandleEndpoints(eventType watch.EventType, endpoints *kapi.Endpoints) error
  • func (p *HostAdmitter) HandleNamespaces(namespaces sets.String) error
  • func (p *HostAdmitter) HandleNode(eventType watch.EventType, node *kapi.Node) error
  • func (p *HostAdmitter) HandleRoute(eventType watch.EventType, route *routeapi.Route) error
  • func (p *HostAdmitter) SetLastSyncProcessed(processed bool) error
• type HostToRouteMap
• type NamespaceLister
• type RejectionRecorder
• type RouteAdmissionFunc
• type RouteHostFunc
• type RouteMap
  • func (srm RouteMap) InsertRoute(key string, route *routeapi.Route)
  • func (srm RouteMap) RemoveRoute(key string, route *routeapi.Route) bool
• type RouteToHostMap
• type RouterController
  • func (c *RouterController) HandleEndpoints()
  • func (c *RouterController) HandleNamespaces()
  • func (c *RouterController) HandleNode()
  • func (c *RouterController) HandleRoute()
  • func (c *RouterController) Run()
• type StatusAdmitter
  • func NewStatusAdmitter(plugin router.Plugin, client client.RoutesNamespacer, name string) *StatusAdmitter
  • func (a *StatusAdmitter) HandleEndpoints(eventType watch.EventType, route *kapi.Endpoints) error
  • func (a *StatusAdmitter) HandleNamespaces(namespaces sets.String) error
  • func (a *StatusAdmitter) HandleNode(eventType watch.EventType, node *kapi.Node) error
  • func (a *StatusAdmitter) HandleRoute(eventType watch.EventType, route *routeapi.Route) error
  • func (a *StatusAdmitter) RecordRouteRejection(route *routeapi.Route, reason, message string)
  • func (a *StatusAdmitter) SetLastSyncProcessed(processed bool) error
• type UniqueHost
  • func NewUniqueHost(plugin router.Plugin, fn RouteHostFunc, recorder RejectionRecorder) *UniqueHost
  • func (p *UniqueHost) HandleEndpoints(eventType watch.EventType, endpoints *kapi.Endpoints) error
  • func (p *UniqueHost) HandleNamespaces(namespaces sets.String) error
  • func (p *UniqueHost) HandleNode(eventType watch.EventType, node *kapi.Node) error
  • func (p *UniqueHost) HandleRoute(eventType watch.EventType, route *routeapi.Route) error
  • func (p *UniqueHost) HostLen() int
  • func (p *UniqueHost) RoutesForHost(host string) ([]*routeapi.Route, bool)
  • func (p *UniqueHost) SetLastSyncProcessed(processed bool) error

Variables

var LogRejections = logRecorder{}

Functions

func HostForRoute

func HostForRoute(route *routeapi.Route) string

HostForRoute returns the host set on the route.

Types

type ExtendedValidator

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

ExtendedValidator implements the router.Plugin interface to provide extended config validation for template based, backend-agnostic routers.

func NewExtendedValidator

func NewExtendedValidator(plugin router.Plugin, recorder RejectionRecorder) *ExtendedValidator

ExtendedValidator creates a plugin wrapper that ensures only routes that pass extended validation are relayed to the next plugin in the chain. Recorder is an interface for indicating why a route was rejected.

func (*ExtendedValidator) HandleEndpoints

func (p *ExtendedValidator) HandleEndpoints(eventType watch.EventType, endpoints *kapi.Endpoints) error

HandleEndpoints processes watch events on the Endpoints resource.

func (*ExtendedValidator) HandleNamespaces

func (p *ExtendedValidator) HandleNamespaces(namespaces sets.String) error

HandleAllowedNamespaces limits the scope of valid routes to only those that match the provided namespace list.

func (*ExtendedValidator) HandleNode

func (p *ExtendedValidator) HandleNode(eventType watch.EventType, node *kapi.Node) error

HandleNode processes watch events on the node resource

func (*ExtendedValidator) HandleRoute

func (p *ExtendedValidator) HandleRoute(eventType watch.EventType, route *routeapi.Route) error

HandleRoute processes watch events on the Route resource.

func (*ExtendedValidator) SetLastSyncProcessed

func (p *ExtendedValidator) SetLastSyncProcessed(processed bool) error

type HostAdmitter

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

HostAdmitter implements the router.Plugin interface to add admission control checks for routes in template based, backend-agnostic routers.

func NewHostAdmitter

func NewHostAdmitter(plugin router.Plugin, fn RouteAdmissionFunc, restrict bool, recorder RejectionRecorder) *HostAdmitter

NewHostAdmitter creates a plugin wrapper that checks whether or not to admit routes and relay them to the next plugin in the chain. Recorder is an interface for indicating why a route was rejected.

func (*HostAdmitter) HandleEndpoints

func (p *HostAdmitter) HandleEndpoints(eventType watch.EventType, endpoints *kapi.Endpoints) error

HandleEndpoints processes watch events on the Endpoints resource.

func (*HostAdmitter) HandleNamespaces

func (p *HostAdmitter) HandleNamespaces(namespaces sets.String) error

HandleAllowedNamespaces limits the scope of valid routes to only those that match the provided namespace list.

func (*HostAdmitter) HandleNode

func (p *HostAdmitter) HandleNode(eventType watch.EventType, node *kapi.Node) error

HandleNode processes watch events on the Node resource.

func (*HostAdmitter) HandleRoute

func (p *HostAdmitter) HandleRoute(eventType watch.EventType, route *routeapi.Route) error

HandleRoute processes watch events on the Route resource.

func (*HostAdmitter) SetLastSyncProcessed

func (p *HostAdmitter) SetLastSyncProcessed(processed bool) error

type HostToRouteMap

type HostToRouteMap map[string][]*routeapi.Route

type NamespaceLister

type NamespaceLister interface {
	NamespaceNames() (sets.String, error)
}

NamespaceLister returns all the names that should be watched by the client

type RejectionRecorder

type RejectionRecorder interface {
	RecordRouteRejection(route *routeapi.Route, reason, message string)
}

RejectionRecorder is an object capable of recording why a route was rejected

type RouteAdmissionFunc

type RouteAdmissionFunc func(*routeapi.Route) error

RouteAdmissionFunc determines whether or not to admit a route.

type RouteHostFunc

type RouteHostFunc func(*routeapi.Route) string

RouteHostFunc returns a host for a route. It may return an empty string.

type RouteMap

type RouteMap map[string][]*routeapi.Route

RouteMap contains all routes associated with a key

func (RouteMap) InsertRoute

func (srm RouteMap) InsertRoute(key string, route *routeapi.Route)

func (RouteMap) RemoveRoute

func (srm RouteMap) RemoveRoute(key string, route *routeapi.Route) bool

RemoveRoute removes any existing routes that match the given route's namespace and name for a key

type RouteToHostMap

type RouteToHostMap map[string]string

type RouterController

type RouterController struct {
	Plugin        router.Plugin
	NextRoute     func() (watch.EventType, *routeapi.Route, error)
	NextNode      func() (watch.EventType, *kapi.Node, error)
	NextEndpoints func() (watch.EventType, *kapi.Endpoints, error)

	RoutesListConsumed    func() bool
	EndpointsListConsumed func() bool

	WatchNodes bool

	Namespaces            NamespaceLister
	NamespaceSyncInterval time.Duration
	NamespaceWaitInterval time.Duration
	NamespaceRetries      int
	// contains filtered or unexported fields
}

RouterController abstracts the details of watching the Route and Endpoints resources from the Plugin implementation being used.

func (*RouterController) HandleEndpoints

func (c *RouterController) HandleEndpoints()

HandleEndpoints handles a single Endpoints event and refreshes the router backend.

func (*RouterController) HandleNamespaces

func (c *RouterController) HandleNamespaces()

func (*RouterController) HandleNode

func (c *RouterController) HandleNode()

HandleNode handles a single Node event and synchronizes the router backend

func (*RouterController) HandleRoute

func (c *RouterController) HandleRoute()

HandleRoute handles a single Route event and synchronizes the router backend.

func (*RouterController) Run

func (c *RouterController) Run()

Run begins watching and syncing.

type StatusAdmitter

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

StatusAdmitter ensures routes added to the plugin have status set.

func NewStatusAdmitter

func NewStatusAdmitter(plugin router.Plugin, client client.RoutesNamespacer, name string) *StatusAdmitter

NewStatusAdmitter creates a plugin wrapper that ensures every accepted route has a status field set that matches this router. The admitter manages an LRU of recently seen conflicting updates to handle when two router processes with differing configurations are writing updates at the same time.

func (*StatusAdmitter) HandleEndpoints

func (a *StatusAdmitter) HandleEndpoints(eventType watch.EventType, route *kapi.Endpoints) error

func (*StatusAdmitter) HandleNamespaces

func (a *StatusAdmitter) HandleNamespaces(namespaces sets.String) error

func (*StatusAdmitter) HandleNode

func (a *StatusAdmitter) HandleNode(eventType watch.EventType, node *kapi.Node) error

func (*StatusAdmitter) HandleRoute

func (a *StatusAdmitter) HandleRoute(eventType watch.EventType, route *routeapi.Route) error

HandleRoute attempts to admit the provided route on watch add / modifications.

func (*StatusAdmitter) RecordRouteRejection

func (a *StatusAdmitter) RecordRouteRejection(route *routeapi.Route, reason, message string)

RecordRouteRejection attempts to update the route status with a reason for a route being rejected.

func (*StatusAdmitter) SetLastSyncProcessed

func (a *StatusAdmitter) SetLastSyncProcessed(processed bool) error

type UniqueHost

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

UniqueHost implements the router.Plugin interface to provide a template based, backend-agnostic router.

func NewUniqueHost

func NewUniqueHost(plugin router.Plugin, fn RouteHostFunc, recorder RejectionRecorder) *UniqueHost

NewUniqueHost creates a plugin wrapper that ensures only unique routes are passed into the underlying plugin. Recorder is an interface for indicating why a route was rejected.

func (*UniqueHost) HandleEndpoints

func (p *UniqueHost) HandleEndpoints(eventType watch.EventType, endpoints *kapi.Endpoints) error

HandleEndpoints processes watch events on the Endpoints resource.

func (*UniqueHost) HandleNamespaces

func (p *UniqueHost) HandleNamespaces(namespaces sets.String) error

HandleAllowedNamespaces limits the scope of valid routes to only those that match the provided namespace list.

func (*UniqueHost) HandleNode

func (p *UniqueHost) HandleNode(eventType watch.EventType, node *kapi.Node) error

HandleNode processes watch events on the Node resource and calls the router

func (*UniqueHost) HandleRoute

func (p *UniqueHost) HandleRoute(eventType watch.EventType, route *routeapi.Route) error

HandleRoute processes watch events on the Route resource. TODO: this function can probably be collapsed with the router itself, as a function that

determines which component needs to be recalculated (which template) and then does so
on demand.

func (*UniqueHost) HostLen

func (p *UniqueHost) HostLen() int

HostLen returns the number of hosts currently tracked by this plugin.

func (*UniqueHost) RoutesForHost

func (p *UniqueHost) RoutesForHost(host string) ([]*routeapi.Route, bool)

RoutesForHost is a helper that allows routes to be retrieved.

func (*UniqueHost) SetLastSyncProcessed

func (p *UniqueHost) SetLastSyncProcessed(processed bool) error