store

May 31, 2022

Changes in this version

type Ingress

+ Addresses []string

+ type IngressCore struct

+ APIVersion string

+ Annotations map[string]string

+ Class string

+ DefaultBackend *IngressPath

+ Name string

+ Namespace string

+ Rules map[string]*IngressRule

+ TLS map[string]*IngressTLS

type K8s

+ PublishServiceAddresses []string

+ SecretsProcessed map[string]struct{}

+ ServiceProcessed map[string]struct{}

+ UpdateStatusFunc func(service Service, ingresses []*Ingress)

+ func (k *K8s) EventPublishService(ns *Namespace, data *Service) (updateRequired bool)

type Service

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

Nov 5, 2021

Changes in this version

type Ingress

+ Ignored bool

type IngressPath

+ SvcNamespace string

Oct 8, 2021

Changes in this version

+ const EXTENSIONSV1BETA1

+ const NETWORKINGV1

+ const NETWORKINGV1BETA1

+ const PATH_TYPE_EXACT

+ const PATH_TYPE_IMPLEMENTATION_SPECIFIC

+ const PATH_TYPE_PREFIX

+ func CopyAnnotations(in map[string]string) map[string]string

+ type CustomResources struct

+ Backends map[string]*models.Backend

+ Defaults map[string]*models.Defaults

+ Global map[string]*models.Global

+ LogTargets map[string]models.LogTargets

type Endpoints

+ SliceName string

+ type ErrNotFound error

type HAProxySrv

+ Port int64

type IngressPath

+ PathTypeMatch string

type K8s

+ NbrHAProxyInst int64

+ func (k *K8s) EventPod(podEvent PodEvent) (updateRequired bool)

+ func (k K8s) GetEndpoints(namespace, name string) (endpoints map[string]*PortEndpoints, err error)

+ func (k K8s) GetSecret(namespace, name string) (*Secret, error)

+ func (k K8s) GetService(namespace, name string) (*Service, error)

type Namespace

+ CRs *CustomResources

+ HAProxyRuntime map[string]map[string]*RuntimeBackend

+ type PodEvent struct

+ Created bool

type PortEndpoints

+ Addresses map[string]struct{}

+ type RuntimeBackend struct

+ DynUpdateFailed bool

+ Endpoints PortEndpoints

+ HAProxySrvs []*HAProxySrv

+ Name string

May 3, 2021

Changes in this version

type ConfigMap

+ Loaded bool

+ type ConfigMaps struct

+ Errorfiles *ConfigMap

+ Main *ConfigMap

+ PatternFiles *ConfigMap

+ TCPServices *ConfigMap

Mar 10, 2021

Changes in this version

type IngressPath

+ SvcName string

+ SvcPortInt int64

+ SvcPortResolved *ServicePort

+ SvcPortString string

Jan 21, 2021

Changes in this version

+ type ConfigMap struct

+ Annotations MapStringW

+ Name string

+ Namespace string

+ Status Status

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

+ type Endpoints struct

+ Namespace string

+ Ports map[string]*PortEndpoints

+ Service StringW

+ Status Status

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

+ type HAProxySrv struct

+ Address string

+ Modified bool

+ Name string

+ type Ingress struct

+ APIVersion string

+ Annotations MapStringW

+ Class string

+ DefaultBackend *IngressPath

+ Name string

+ Namespace string

+ Rules map[string]*IngressRule

+ Status Status

+ TLS map[string]*IngressTLS

+ func ConvertToIngress(resource interface{}) (ingress *Ingress, err error)

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

+ type IngressClass struct

+ APIVersion string

+ Controller string

+ Name string

+ Status Status

+ func ConvertToIngressClass(resource interface{}) (ingress *IngressClass, err error)

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

+ type IngressPath struct

+ ExactPathMatch bool

+ IsDefaultBackend bool

+ Path string

+ ServiceName string

+ ServicePortInt int64

+ ServicePortString string

+ Status Status

+ 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

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

+ type K8s struct

+ ConfigMaps map[string]*ConfigMap

+ IngressClasses map[string]*IngressClass

+ Namespaces map[string]*Namespace

+ NamespacesAccess NamespacesWatch

+ func NewK8sStore() K8s

+ func (k K8s) Clean()

+ func (k K8s) EventConfigMap(ns *Namespace, data *ConfigMap, configMapArgs map[string]utils.NamespaceValue) (updateRequired bool, configMap string)

+ func (k K8s) EventEndpoints(ns *Namespace, data *Endpoints, ...) (updateRequired bool)

+ func (k K8s) EventIngress(ns *Namespace, data *Ingress, controllerClass string) (updateRequired bool)

+ func (k K8s) EventIngressClass(data *IngressClass) (updateRequired bool)

+ func (k K8s) EventNamespace(ns *Namespace, data *Namespace) (updateRequired bool)

+ func (k K8s) EventSecret(ns *Namespace, data *Secret) (updateRequired bool)

+ func (k K8s) EventService(ns *Namespace, data *Service) (updateRequired bool)

+ func (k K8s) FetchSecret(secretPath, defaultNs string) (*Secret, error)

+ func (k K8s) GetNamespace(name string) *Namespace

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

+ func (k K8s) SetDefaultAnnotation(annotation, value string)

+ 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 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 PortEndpoints struct

+ AddrCount int

+ AddrNew map[string]struct{}

+ BackendName string

+ DynUpdateFailed bool

+ HAProxySrvs []*HAProxySrv

+ Port int64

+ func (oldE *PortEndpoints) Equal(newE *PortEndpoints) bool

+ 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

+ DNS string

+ 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 (a *StringW) Equal(b *StringW) bool