Versions in this module Expand all Collapse all v0 v0.1.1 Jun 19, 2017 v0.1.0 May 18, 2017 Changes in this version + const ErrMsgTmplInvalidAnnotationName + const ErrMsgTmplInvalidLabelSelector + const ErrMsgTmplInvalidPath + const ErrMsgTmplInvalidPort + const ErrMsgTmplInvalidServerReturnHTTPStatusCode + const ErrMsgTmplInvalidServerReturnURL + const ErrMsgTmplMissingSSLKey + const ErrMsgTmplSSLCertMissing + func ProcessEvent(cache *Cache, resourceType WatchableResourceSet, event watch.Event) bool + type Cache struct + Namespaces map[string]*Namespace + Pods map[string]*PodWithRoutes + Secrets map[string]*Secret + func NewCache() *Cache + type Config struct + APIKeySecret string + APIKeySecretDataField string + NamespaceEnvLabel string + NamespaceHostsAnnotation string + NamespaceOrgLabel string + Nginx NginxConfig + PodsAppNameLabel string + PodsAppRevLabel string + PodsPathsAnnotation string + RoutableLabelSelector string + func ConfigFromEnv() (*Config, error) + type HealthCheck struct + HTTPCheck bool + HealthyThreshold int32 + IntervalMs int32 + Method string + Path string + Port int32 + TimeoutMs int32 + UnhealthyThreshold int32 + type HostOptions struct + SSLOptions *SSLOptions + type Incoming struct + Path string + type Namespace struct + Environment string + Hosts map[string]HostOptions + Name string + Organization string + func (ns Namespace) Hash() uint64 + func (ns Namespace) ID() string + type NamespaceWatchableSet struct + Config *Config + KubeClient *kubernetes.Clientset + func (s NamespaceWatchableSet) CacheAdd(cache *Cache, item WatchableResource) + func (s NamespaceWatchableSet) CacheCompare(cache *Cache, newItem WatchableResource) bool + func (s NamespaceWatchableSet) CacheRemove(cache *Cache, id string) + func (s NamespaceWatchableSet) ConvertToModel(in interface{}) WatchableResource + func (s NamespaceWatchableSet) Get() ([]WatchableResource, string, error) + func (s NamespaceWatchableSet) IDFromObject(in interface{}) string + func (s NamespaceWatchableSet) Watch(resouceVersion string) (watch.Interface, error) + func (s NamespaceWatchableSet) Watchable(in interface{}) bool + type NginxConfig struct + APIKeyHeader string + DefaultLocationReturn string + EnableHealthChecks bool + MaxClientBodySize string + Port int + RunInMockMode bool + SSLCert string + SSLCertificateDir string + SSLEnabled bool + SSLKey string + SSLPort int + StatusPath string + type OptionValue struct + ValueFrom *ValueFrom + type Outgoing struct + HealthCheck *HealthCheck + IP string + Port string + TargetPath *string + Weight *uint + type PodWatchableSet struct + Config *Config + KubeClient *kubernetes.Clientset + func (s PodWatchableSet) CacheAdd(cache *Cache, item WatchableResource) + func (s PodWatchableSet) CacheCompare(cache *Cache, newItem WatchableResource) bool + func (s PodWatchableSet) CacheRemove(cache *Cache, id string) + func (s PodWatchableSet) ConvertToModel(in interface{}) WatchableResource + func (s PodWatchableSet) Get() ([]WatchableResource, string, error) + func (s PodWatchableSet) IDFromObject(in interface{}) string + func (s PodWatchableSet) Watch(resouceVersion string) (watch.Interface, error) + func (s PodWatchableSet) Watchable(in interface{}) bool + type PodWithRoutes struct + AppName string + AppRevision string + Name string + Namespace string + Routes []*Route + Status api.PodPhase + func (pod PodWithRoutes) Hash() uint64 + func (pod PodWithRoutes) ID() string + type Route struct + Incoming *Incoming + Outgoing *Outgoing + func GetRoutes(config *Config, pod *api.Pod) []*Route + type SSLOptions struct + Certificate OptionValue + ClientCertficate *OptionValue + Key OptionValue + type Secret struct + Fields map[string][]byte + Namespace string + RoutingKey *[]byte + func (s Secret) Hash() uint64 + func (s Secret) ID() string + type SecretRef struct + Key string + type SecretWatchableSet struct + Config *Config + KubeClient *kubernetes.Clientset + func (s SecretWatchableSet) CacheAdd(cache *Cache, item WatchableResource) + func (s SecretWatchableSet) CacheCompare(cache *Cache, newItem WatchableResource) bool + func (s SecretWatchableSet) CacheRemove(cache *Cache, id string) + func (s SecretWatchableSet) ConvertToModel(in interface{}) WatchableResource + func (s SecretWatchableSet) Get() ([]WatchableResource, string, error) + func (s SecretWatchableSet) IDFromObject(in interface{}) string + func (s SecretWatchableSet) Watch(resouceVersion string) (watch.Interface, error) + func (s SecretWatchableSet) Watchable(in interface{}) bool + type ValueFrom struct + SecretKeyRef *SecretRef + type WatchableResource interface + Hash func() uint64 + ID func() string + type WatchableResourceSet interface + CacheAdd func(*Cache, WatchableResource) + CacheCompare func(*Cache, WatchableResource) bool + CacheRemove func(*Cache, string) + ConvertToModel func(interface{}) WatchableResource + Get func() ([]WatchableResource, string, error) + IDFromObject func(interface{}) string + Watch func(resouceVersion string) (watch.Interface, error) + Watchable func(interface{}) bool