Versions in this module Expand all Collapse all v1 v1.5.1 Apr 28, 2017 Changes in this version + var LogRejections = logRecorder + func GetNameForHost(name string) string + func GetSafeRouteName(name string) string + func HostForRoute(route *routeapi.Route) string + func IsGeneratedRouteName(name string) 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 HostToRouteMap map[string][]*routeapi.Route + type IngressTranslator struct + func NewIngressTranslator(kc kcoreclient.SecretsGetter) *IngressTranslator + func (it *IngressTranslator) TranslateIngressEvent(eventType watch.EventType, ingress *extensions.Ingress) []ingressRouteEvents + func (it *IngressTranslator) TranslateSecretEvent(eventType watch.EventType, secret *kapi.Secret) (events []ingressRouteEvents) + func (it *IngressTranslator) UpdateNamespaces(namespaces sets.String) + type NamespaceLister interface + NamespaceNames func() (sets.String, 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 RouteToHostMap map[string]string + type RouterController struct + EnableIngress bool + EndpointsListConsumed func() bool + EndpointsListCount func() int + EndpointsListSuccessfulAtLeastOnce func() bool + IngressTranslator *IngressTranslator + IngressesListConsumed func() bool + IngressesListCount func() int + IngressesListSuccessfulAtLeastOnce func() bool + NamespaceRetries int + NamespaceSyncInterval time.Duration + NamespaceWaitInterval time.Duration + Namespaces NamespaceLister + NextEndpoints func() (watch.EventType, *kapi.Endpoints, error) + NextIngress func() (watch.EventType, *extensions.Ingress, error) + NextNode func() (watch.EventType, *kapi.Node, error) + NextRoute func() (watch.EventType, *routeapi.Route, error) + NextSecret func() (watch.EventType, *kapi.Secret, error) + Plugin router.Plugin + RoutesListConsumed func() bool + RoutesListCount func() int + RoutesListSuccessfulAtLeastOnce func() bool + SecretsListConsumed func() bool + SecretsListCount func() int + SecretsListSuccessfulAtLeastOnce func() bool + WatchNodes bool + func (c *RouterController) HandleEndpoints() + func (c *RouterController) HandleIngress() + func (c *RouterController) HandleNamespaces() + func (c *RouterController) HandleNode() + func (c *RouterController) HandleRoute() + func (c *RouterController) HandleSecret() + func (c *RouterController) Run() + type StatusAdmitter struct + func NewStatusAdmitter(plugin router.Plugin, client client.RoutesNamespacer, name, hostName string) *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, fn RouteHostFunc, disableOwnershipCheck bool, ...) *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) v1.5.0-alpha.1 Dec 29, 2016 Incompatible versions in this module v3.10.0-rc.0+incompatible Jun 15, 2018 v3.7.0-alpha.0+incompatible Aug 1, 2017
Go to main page