controller

May 31, 2022

Changes in this version

+ const PUBLISH_SERVICE

Oct 8, 2021

Changes in this version

+ const CUSTOM_RESOURCE

+ const CoreGroupVersion

+ const POD

+ type BackendCR struct

+ func NewBackendCR() BackendCR

+ func (c BackendCR) GetInformer(eventChan chan SyncDataEvent, factory informers.SharedInformerFactory) cache.SharedIndexInformer

+ func (c BackendCR) GetKind() string

+ func (c BackendCR) ProcessEvent(s *store.K8s, job SyncDataEvent) bool

+ type CR interface

+ GetInformer func(chan SyncDataEvent, informers.SharedInformerFactory) cache.SharedIndexInformer

+ GetKind func() string

+ ProcessEvent func(*store.K8s, SyncDataEvent) bool

+ type CRManager struct

+ func NewCRManager(s *store.K8s, restCfg *rest.Config, cacheResync time.Duration, ...) CRManager

+ func (m CRManager) EventCustomResource(job SyncDataEvent) bool

+ func (m CRManager) RegisterCoreCR(cr CR)

+ func (m CRManager) RunInformers(namespace string) []cache.InformerSynced

+ type DefaultsCR struct

+ func NewDefaultsCR() DefaultsCR

+ func (c DefaultsCR) GetInformer(eventChan chan SyncDataEvent, factory informers.SharedInformerFactory) cache.SharedIndexInformer

+ func (c DefaultsCR) GetKind() string

+ func (c DefaultsCR) ProcessEvent(s *store.K8s, job SyncDataEvent) bool

+ type GlobalCR struct

+ func NewGlobalCR() GlobalCR

+ func (c GlobalCR) GetInformer(eventChan chan SyncDataEvent, factory informers.SharedInformerFactory) cache.SharedIndexInformer

+ func (c GlobalCR) GetKind() string

+ func (c GlobalCR) ProcessEvent(s *store.K8s, job SyncDataEvent) bool

type HAProxyController

+ PodNamespace string

+ PodPrefix string

type K8s

+ RestConfig *rest.Config

+ func (k *K8s) EventPods(namespace, podPrefix string, resyncPeriod time.Duration, ...)

+ func (k *K8s) EventsEndpointSlices(channel chan SyncDataEvent, stop chan struct{}, ...)

type SyncDataEvent

+ CRKind string

+ Name string

Dec 1, 2021

Changes in this version

type HAProxyController

+ func (c *HAProxyController) UpdateIngress()

+ type SyncIngress struct

+ Ingress *store.Ingress

+ Service *corev1.Service

Jul 15, 2021

Changes in this version

type K8s

+ DisableServiceExternalName bool

May 3, 2021

Changes in this version

type HAProxyController

+ AuxCfgModTime int64

+ Cfg config.ControllerCfg

+ OSArgs utils.OSArgs

Feb 3, 2021

Changes in this version

type HAProxyController

+ func (c *HAProxyController) Stop()

Jan 21, 2021

Changes in this version

+ const CONTROLLER_CLASS

+ const Errorfiles

+ const HOST

+ const Main

+ const PATH_EXACT

+ const PATH_PREFIX

+ const SNI

+ const SSLDefaultBaceknd

+ const TCPServices

+ var HAProxyBdCertDir string

+ var HAProxyBinary string

+ var HAProxyCaCertDir string

+ var HAProxyCfgDir string

+ var HAProxyErrFileDir string

+ var HAProxyFtCertDir string

+ var HAProxyRuntimeSocket string

type Configuration

+ Certificates *haproxy.Certificates

+ HAProxyRules *haproxy.Rules

+ IngressRoutes ingress.Routes

+ func (c *Configuration) HAProxyRulesInit() error

+ type ErrorFile struct

+ func (e ErrorFile) Update(k store.K8s, cfg *Configuration, api api.HAProxyClient) (reload bool, err error)

type HAProxyController

+ IngressClass string

+ PublishService *store.Service

+ Store store.K8s

+ UpdateHandlers []UpdateHandler

+ type HTTPS struct

+ func (h HTTPS) Update(k store.K8s, cfg *Configuration, api api.HAProxyClient) (reload bool, err error)

type K8s

+ func (k *K8s) EventsIngressClass(channel chan *store.IngressClass, stop chan struct{}, ...)

+ func (k *K8s) IsNetworkingV1ApiSupported() bool

+ func (k *K8s) IsNetworkingV1Beta1ApiSupported() bool

+ type ProxyProtocol struct

+ func (p ProxyProtocol) Update(k store.K8s, cfg *Configuration, api api.HAProxyClient) (reload bool, err error)

+ type RefreshHandler struct

+ func (h RefreshHandler) Update(k store.K8s, cfg *Configuration, api api.HAProxyClient) (reload bool, err error)

+ type SourceIPHeader struct

+ func (p SourceIPHeader) Update(k store.K8s, cfg *Configuration, api api.HAProxyClient) (reload bool, err error)

type SyncType

+ const INGRESS_CLASS

+ type TCPHandler struct

+ func (t TCPHandler) Update(k store.K8s, cfg *Configuration, api api.HAProxyClient) (reload bool, err error)

+ type UpdateHandler interface

+ Update func(k store.K8s, cfg *Configuration, api api.HAProxyClient) (reload bool, err error)

Jan 7, 2021

Changes in this version

type FrontendHTTPReqs

+ Presence map[uint64]struct{}

+ Store []models.HTTPRequestRule

+ func NewFrontendHTTPReqs() *FrontendHTTPReqs

+ func (frontendHTTPReqs *FrontendHTTPReqs) Add(key uint64, rule models.HTTPRequestRule)

type FrontendTCPReqs

+ Presence map[uint64]struct{}

+ Store []models.TCPRequestRule

+ func NewFrontendTCPReqs() *FrontendTCPReqs

+ func (frontendTCPReqs *FrontendTCPReqs) Add(key uint64, rule models.TCPRequestRule)

type PortEndpoints

+ DynUpdateFailed bool

Dec 20, 2020

Changes in this version

type HAProxySrv

+ Name string

type PortEndpoints

+ AddrNew map[string]struct{}

Dec 18, 2020

Changes in this version

type PortEndpoints

+ AddrCount int

Nov 20, 2020

Changes in this version

+ var TransactionDir string

+ type HAProxySrv struct

+ Address string

+ Modified bool

+ type PortEndpoints struct

+ AddrRemain map[string]struct{}

+ AddrsUsed map[string]struct{}

+ BackendName string

+ HAProxySrvs map[string]*HAProxySrv

+ Port int64

+ func (a *PortEndpoints) Equal(b *PortEndpoints) bool

Oct 25, 2020

Changes in this version

type Rule

+ const REQUEST_PATH_REWRITE

+ const REQUEST_SET_HOST

Jun 2, 2020

Changes in this version

type HAProxyController

+ Client api.HAProxyClient

May 7, 2020

Changes in this version

+ const TRACE_API

+ var HAProxyPIDFile string

type Configuration

+ FrontendHTTPReqRules map[Rule]FrontendHTTPReqs

+ FrontendHTTPRspRules map[Rule]FrontendHTTPRsps

+ type FrontendHTTPRsps map[uint64]models.HTTPResponseRule

type HAProxyController

+ HAProxyCfgDir string

+ Logger utils.Logger

+ func (c *HAProxyController) FrontendHTTPRspsRefresh() (reload bool)

+ func (c *HAProxyController) HAProxyProcess() (*os.Process, error)

type K8s

+ Logger utils.Logger

type Rule

+ const RESPONSE_SET_HEADER

type Service

+ DNS string

Apr 14, 2020

Changes in this version

+ type BackendHTTPReqs struct

type Configuration

+ BackendHTTPRules map[string]BackendHTTPReqs

+ FrontendHTTPRules map[Rule]FrontendHTTPReqs

+ FrontendRulesStatus map[Mode]Status

+ FrontendTCPRules map[Rule]FrontendTCPReqs

+ type FrontendHTTPReqs map[uint64]models.HTTPRequestRule

+ type FrontendTCPReqs map[uint64]models.TCPRequestRule

type HAProxyController

+ func (c *HAProxyController) BackendHTTPReqsRefresh() (reload bool)

+ func (c *HAProxyController) FrontendHTTPReqsRefresh() (reload bool)

+ func (c *HAProxyController) FrontendTCPreqsRefresh() (reload bool)

type Mode

+ const HTTP

+ const TCP

type Rule

+ const PATH_REWRITE

+ const SET_HOST

Mar 24, 2020

Changes in this version

type Rule

+ const BLACKLIST

Mar 17, 2020

Changes in this version

+ var HAProxyMapDir string

type Configuration

+ IngressClass string

+ MapFiles haproxy.Maps

type HAProxyController

+ func (c *HAProxyController) RequestsTCPRefresh() (needsReload bool)

+ type HTTPRequestRules map[uint64]models.HTTPRequestRule

type IngressTLS

+ func (a *IngressTLS) Equal(b *IngressTLS) bool

+ type Rule string

+ const PROXY_PROTOCOL

+ const REQUEST_SET_HEADER

+ const SSL_REDIRECT

+ const WHITELIST

+ type TCPRequestRules map[uint64]models.TCPRequestRule

Mar 4, 2020

Changes in this version

+ const DEBUG_API

+ const FrontendHTTP

+ const FrontendHTTPS

+ const FrontendSSL

+ const HTTP_REDIRECT

+ const RATE_LIMIT

+ const REQUEST_CAPTURE

+ var ErrIgnored = errors.New("Ignored resource")

+ var HAProxyCFG string

+ var HAProxyCaptureDir string

+ var HAProxyCertDir string

+ var HAProxyStateDir string

+ func ConvertIngressRules(ingressRules []extensions.IngressRule) map[string]*IngressRule

+ func ConvertIngressTLS(ingressTLS []extensions.IngressTLS) map[string]*IngressTLS

+ func SetDefaultAnnotation(annotation, value string)

+ type ConfigMap struct

+ Annotations MapStringW

+ Name string

+ Namespace string

+ Status Status

+ func (a *ConfigMap) Equal(b *ConfigMap) bool

+ type Configuration struct

+ BackendSwitchingRules map[string]UseBackendRules

+ BackendSwitchingStatus map[string]struct{}

+ ConfigMap *ConfigMap

+ ConfigMapTCPServices *ConfigMap

+ HTTPRequests map[string][]models.HTTPRequestRule

+ HTTPRequestsStatus Status

+ HTTPS bool

+ Namespace map[string]*Namespace

+ NamespacesAccess NamespacesWatch

+ PublishService *Service

+ RateLimitingEnabled bool

+ SSLPassthrough bool

+ SSLRedirect bool

+ TCPRequests map[string][]models.TCPRequestRule

+ TCPRequestsStatus Status

+ func (c *Configuration) Clean()

+ func (c *Configuration) GetNamespace(name string) *Namespace

+ func (c *Configuration) Init(osArgs utils.OSArgs, api *clientnative.HAProxyClient)

+ func (c *Configuration) IsRelevantNamespace(namespace string) bool

+ func (c *Configuration) NewNamespace(name string) *Namespace

+ type EndpointIP struct

+ Disabled bool

+ HAProxyName string

+ IP string

+ Name string

+ Status Status

+ func (a *EndpointIP) Equal(b *EndpointIP) bool

+ type EndpointIPs map[string]*EndpointIP

+ func (a *EndpointIPs) Equal(b *EndpointIPs) bool

+ type EndpointPort struct

+ Name string

+ Port int64

+ Protocol string

+ Status Status

+ func (a *EndpointPort) Equal(b *EndpointPort) bool

+ type EndpointPorts []*EndpointPort

+ func (a *EndpointPorts) Equal(b *EndpointPorts) bool

+ type Endpoints struct

+ Addresses *EndpointIPs

+ BackendName string

+ Namespace string

+ Ports *EndpointPorts

+ Service StringW

+ Status Status

+ func (a *Endpoints) Equal(b *Endpoints) bool

+ type HAProxyController struct

+ ActiveTransaction string

+ ActiveTransactionHasChanges bool

+ NativeAPI *clientnative.HAProxyClient

+ func (c *HAProxyController) ActiveConfiguration() (*parser.Parser, error)

+ func (c *HAProxyController) HAProxyInitialize()

+ func (c *HAProxyController) HAProxyReload() error

+ func (c *HAProxyController) RequestsHTTPRefresh() (needsReload bool, err error)

+ func (c *HAProxyController) Start(ctx context.Context, osArgs utils.OSArgs)

+ func (c *HAProxyController) SyncData(jobChan <-chan SyncDataEvent, chConfigMapReceivedAndProcessed chan bool)

+ type Ingress struct

+ Annotations MapStringW

+ DefaultBackend *IngressPath

+ Name string

+ Namespace string

+ Rules map[string]*IngressRule

+ Status Status

+ TLS map[string]*IngressTLS

+ func (a *Ingress) Equal(b *Ingress) bool

+ type IngressPath struct

+ IsDefaultBackend bool

+ IsSSLPassthrough bool

+ IsTCPService bool

+ Path string

+ ServiceName string

+ ServicePortInt int64

+ ServicePortString string

+ Status Status

+ TargetPort int64

+ func ConvertIngressBackend(ingressBackend *extensions.IngressBackend) *IngressPath

+ func (a *IngressPath) Equal(b *IngressPath) bool

+ type IngressRule struct

+ Host string

+ Paths map[string]*IngressPath

+ Status Status

+ func (a *IngressRule) Equal(b *IngressRule) bool

+ type IngressTLS struct

+ Host string

+ SecretName StringW

+ Status Status

+ type K8s struct

+ API *kubernetes.Clientset

+ func GetKubernetesClient() (*K8s, error)

+ func GetRemoteKubernetesClient(kubeconfig string) (*K8s, error)

+ func (k *K8s) EventsConfigfMaps(channel chan *ConfigMap, stop chan struct{})

+ func (k *K8s) EventsEndpoints(channel chan *Endpoints, stop chan struct{})

+ func (k *K8s) EventsIngresses(channel chan *Ingress, stop chan struct{})

+ func (k *K8s) EventsNamespaces(channel chan *Namespace, stop chan struct{})

+ func (k *K8s) EventsSecrets(channel chan *Secret, stop chan struct{})

+ func (k *K8s) EventsServices(channel chan *Service, stop chan struct{}, publishSvc *Service)

+ func (k *K8s) GetPublishServiceAddresses(service *corev1.Service, publishSvc *Service)

+ func (k *K8s) UpdateIngressStatus(ingress *Ingress, publishSvc *Service) (err error)

+ type MapStringW map[string]*StringW

+ func ConvertToMapStringW(annotations map[string]string) MapStringW

+ func (a *MapStringW) Clean()

+ func (a *MapStringW) Clone() MapStringW

+ func (a *MapStringW) Equal(b MapStringW) bool

+ func (a *MapStringW) Get(name string) (data *StringW, err error)

+ func (a *MapStringW) SetStatus(old MapStringW) (different bool)

+ func (a *MapStringW) SetStatusState(state Status)

+ func (a *MapStringW) String() string

+ type Mode string

+ const ModeHTTP

+ const ModeTCP

+ func (n *Mode) UnmarshalFlag(value string) error

+ func (n Mode) MarshalFlag() (string, error)

+ type Namespace struct

+ Endpoints map[string]*Endpoints

+ Ingresses map[string]*Ingress

+ Name string

+ Relevant bool

+ Secret map[string]*Secret

+ Services map[string]*Service

+ Status Status

+ type NamespacesWatch struct

+ Blacklist map[string]struct{}

+ Whitelist map[string]struct{}

+ type Secret struct

+ Data map[string][]byte

+ Name string

+ Namespace string

+ Status Status

+ func (a *Secret) Equal(b *Secret) bool

+ type Service struct

+ Addresses []string

+ Annotations MapStringW

+ Name string

+ Namespace string

+ Ports []ServicePort

+ Selector MapStringW

+ Status Status

+ func (a *Service) Equal(b *Service) bool

+ type ServicePort struct

+ Name string

+ Port int64

+ Protocol string

+ Status Status

+ func (a *ServicePort) Equal(b *ServicePort) bool

+ type Status string

+ const ADDED

+ const DELETED

+ const EMPTY

+ const ERROR

+ const MODIFIED

+ type StringW struct

+ OldValue string

+ Status Status

+ Value string

+ func GetValueFromAnnotations(annotationName string, annotations ...MapStringW) (data *StringW, err error)

+ func (a *StringW) Equal(b *StringW) bool

+ type SyncDataEvent struct

+ Data interface{}

+ Namespace string

+ type SyncType string

+ const COMMAND

+ const CONFIGMAP

+ const ENDPOINTS

+ const INGRESS

+ const NAMESPACE

+ const SECRET

+ const SERVICE

+ type UseBackendRule struct

+ Backend string

+ Host string

+ Namespace string

+ Path string

+ type UseBackendRules map[string]UseBackendRule