Versions in this module Expand all Collapse all v1 v1.0.0 Jul 24, 2018 Changes in this version + var LogRejections = logRecorder + func HostForRoute(route *routeapi.Route) string + type ContentionTracker interface + Clear func(id string, current *routeapi.RouteIngress) + IsChangeContended func(id string, now time.Time, current *routeapi.RouteIngress) bool + type ExtendedValidator struct + func NewExtendedValidator(plugin router.Plugin, recorder RejectionRecorder) *ExtendedValidator + func (p *ExtendedValidator) Commit() error + 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 + type HostAdmitter struct + func NewHostAdmitter(plugin router.Plugin, fn RouteAdmissionFunc, ...) *HostAdmitter + func (p *HostAdmitter) Commit() error + 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 + type RejectionRecorder interface + RecordRouteRejection func(route *routeapi.Route, reason, message string) + type RouteAdmissionFunc func(*routeapi.Route) error + type RouteHostFunc func(*routeapi.Route) string + type RouteMap map[string][]*routeapi.Route + func (srm RouteMap) InsertRoute(key string, route *routeapi.Route) + func (srm RouteMap) RemoveRoute(key string, route *routeapi.Route) bool + type RouterController struct + FilteredNamespaceNames sets.String + NamespaceEndpoints map[string]map[string]*kapi.Endpoints + NamespaceLabels labels.Selector + NamespaceRoutes map[string]map[string]*routeapi.Route + Plugin router.Plugin + ProjectClient projectclient.ProjectResourceInterface + ProjectLabels labels.Selector + ProjectRetries int + ProjectSyncInterval time.Duration + ProjectWaitInterval time.Duration + WatchNodes bool + func (c *RouterController) Commit() + func (c *RouterController) GetFilteredProjectNames() (sets.String, error) + func (c *RouterController) HandleEndpoints(eventType watch.EventType, obj interface{}) + func (c *RouterController) HandleNamespace(eventType watch.EventType, obj interface{}) + func (c *RouterController) HandleNode(eventType watch.EventType, obj interface{}) + func (c *RouterController) HandleProjects() + func (c *RouterController) HandleRoute(eventType watch.EventType, obj interface{}) + func (c *RouterController) RecordNamespaceEndpoints(eventType watch.EventType, ep *kapi.Endpoints) + func (c *RouterController) RecordNamespaceRoutes(eventType watch.EventType, rt *routeapi.Route) + func (c *RouterController) Run() + func (c *RouterController) UpdateNamespaces() + type SimpleContentionTracker struct + func NewSimpleContentionTracker(informer cache.SharedInformer, routerName string, interval time.Duration) *SimpleContentionTracker + func (t *SimpleContentionTracker) Changed(id string, current *routeapi.RouteIngress) + func (t *SimpleContentionTracker) Clear(id string, current *routeapi.RouteIngress) + func (t *SimpleContentionTracker) IsChangeContended(id string, now time.Time, current *routeapi.RouteIngress) bool + func (t *SimpleContentionTracker) Run(stopCh <-chan struct{}) + func (t *SimpleContentionTracker) SetConflictMessage(message string) + type StatusAdmitter struct + func NewStatusAdmitter(plugin router.Plugin, client client.RoutesGetter, ...) *StatusAdmitter + func (a *StatusAdmitter) Commit() error + 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) + type UniqueHost struct + func NewUniqueHost(plugin router.Plugin, disableOwnershipCheck bool, recorder RejectionRecorder) *UniqueHost + func (p *UniqueHost) Commit() error + 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)
Go to main page