controller

Apr 21, 2017

Changes in this version

+ func GetNameForHost(name string) string

+ func GetSafeRouteName(name string) string

+ func IsGeneratedRouteName(name string) bool

type ExtendedValidator

+ func (p *ExtendedValidator) Commit() error

type HostAdmitter

+ func (p *HostAdmitter) Commit() error

+ 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 RouterController

+ EnableIngress bool

+ EndpointsListCount func() int

+ EndpointsListSuccessfulAtLeastOnce func() bool

+ IngressTranslator *IngressTranslator

+ IngressesListConsumed func() bool

+ IngressesListCount func() int

+ IngressesListSuccessfulAtLeastOnce func() bool

+ NextIngress func() (watch.EventType, *extensions.Ingress, error)

+ NextSecret func() (watch.EventType, *kapi.Secret, error)

+ RoutesListCount func() int

+ RoutesListSuccessfulAtLeastOnce func() bool

+ SecretsListConsumed func() bool

+ SecretsListCount func() int

+ SecretsListSuccessfulAtLeastOnce func() bool

+ func (c *RouterController) HandleIngress()

+ func (c *RouterController) HandleSecret()

type StatusAdmitter

+ func (a *StatusAdmitter) Commit() error

type UniqueHost

+ func (p *UniqueHost) Commit() error

Jan 14, 2017

Changes in this version

type ExtendedValidator

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

+ type HostAdmitter struct

+ 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 RouteAdmissionFunc func(*routeapi.Route) error

+ 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

+ NextNode func() (watch.EventType, *kapi.Node, error)

+ WatchNodes bool

+ func (c *RouterController) HandleNode()

type StatusAdmitter

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

type UniqueHost

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

Oct 14, 2016

Changes in this version

+ var LogRejections = logRecorder

+ type ExtendedValidator struct

+ 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) HandleRoute(eventType watch.EventType, route *routeapi.Route) error

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

+ type RejectionRecorder interface

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

type RouterController

+ EndpointsListConsumed func() bool

+ RoutesListConsumed func() bool

+ type StatusAdmitter struct

+ 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) 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 (p *UniqueHost) SetLastSyncProcessed(processed bool) error

Oct 29, 2015

Changes in this version

+ func HostForRoute(route *routeapi.Route) string

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

+ type NamespaceLister interface

+ NamespaceNames func() (sets.String, error)

+ type RouteHostFunc func(*routeapi.Route) string

+ type RouteToHostMap map[string]string

type RouterController

+ NamespaceRetries int

+ NamespaceSyncInterval time.Duration

+ NamespaceWaitInterval time.Duration

+ Namespaces NamespaceLister

+ func (c *RouterController) HandleNamespaces()

+ type UniqueHost struct

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

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

+ func (p *UniqueHost) HandleNamespaces(namespaces sets.String) 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)

Jun 18, 2015

Changes in this version

+ type RouterController struct

+ NextEndpoints func() (watch.EventType, *kapi.Endpoints, error)

+ NextRoute func() (watch.EventType, *routeapi.Route, error)

+ Plugin router.Plugin

+ func (c *RouterController) HandleEndpoints()

+ func (c *RouterController) HandleRoute()

+ func (c *RouterController) Run()