Versions in this module Expand all Collapse all v3 v3.4.3 Dec 27, 2023 Changes in this version + const IngressControllerName + func GetK8sVersion(client kubernetes.Interface) (v *version.Version, err error) + func ParseNamespaceName(value string) (ns string, name string, err error) + func ValidateEscapedString(body string, examples ...string) error + type Configuration struct + func NewConfiguration(hasCorrectIngressClass func(interface{}) bool, isPlus bool, ...) *Configuration + func (c *Configuration) AddOrUpdateGlobalConfiguration(gc *conf_v1.GlobalConfiguration) ([]ResourceChange, []ConfigurationProblem, error) + func (c *Configuration) AddOrUpdateIngress(ing *networking.Ingress) ([]ResourceChange, []ConfigurationProblem) + func (c *Configuration) AddOrUpdateTransportServer(ts *conf_v1.TransportServer) ([]ResourceChange, []ConfigurationProblem) + func (c *Configuration) AddOrUpdateVirtualServer(vs *conf_v1.VirtualServer) ([]ResourceChange, []ConfigurationProblem) + func (c *Configuration) AddOrUpdateVirtualServerRoute(vsr *conf_v1.VirtualServerRoute) ([]ResourceChange, []ConfigurationProblem) + func (c *Configuration) DeleteGlobalConfiguration() ([]ResourceChange, []ConfigurationProblem) + func (c *Configuration) DeleteIngress(key string) ([]ResourceChange, []ConfigurationProblem) + func (c *Configuration) DeleteTransportServer(key string) ([]ResourceChange, []ConfigurationProblem) + func (c *Configuration) DeleteVirtualServer(key string) ([]ResourceChange, []ConfigurationProblem) + func (c *Configuration) DeleteVirtualServerRoute(key string) ([]ResourceChange, []ConfigurationProblem) + func (c *Configuration) FindResourcesForAppProtectDosProtected(namespace string, name string) []Resource + func (c *Configuration) FindResourcesForAppProtectLogConfAnnotation(logConfNamespace string, logConfName string) []Resource + func (c *Configuration) FindResourcesForAppProtectPolicyAnnotation(policyNamespace string, policyName string) []Resource + func (c *Configuration) FindResourcesForEndpoints(endpointsNamespace string, endpointsName string) []Resource + func (c *Configuration) FindResourcesForPolicy(policyNamespace string, policyName string) []Resource + func (c *Configuration) FindResourcesForSecret(secretNamespace string, secretName string) []Resource + func (c *Configuration) FindResourcesForService(svcNamespace string, svcName string) []Resource + func (c *Configuration) GetGlobalConfiguration() *conf_v1.GlobalConfiguration + func (c *Configuration) GetResources() []Resource + func (c *Configuration) GetResourcesWithFilter(filter resourceFilter) []Resource + func (c *Configuration) GetTransportServerMetrics() *TransportServerMetrics + type ConfigurationProblem struct + IsError bool + Message string + Object runtime.Object + Reason string + type IngressConfiguration struct + ChildWarnings map[string][]string + Ingress *networking.Ingress + IsMaster bool + Minions []*MinionConfiguration + ValidHosts map[string]bool + Warnings []string + func NewMasterIngressConfiguration(ing *networking.Ingress, minions []*MinionConfiguration, ...) *IngressConfiguration + func NewRegularIngressConfiguration(ing *networking.Ingress) *IngressConfiguration + func (ic *IngressConfiguration) AddWarning(warning string) + func (ic *IngressConfiguration) GetKeyWithKind() string + func (ic *IngressConfiguration) GetObjectMeta() *metav1.ObjectMeta + func (ic *IngressConfiguration) IsEqual(resource Resource) bool + func (ic *IngressConfiguration) Wins(resource Resource) bool + type LoadBalancerController struct + func NewLoadBalancerController(input NewLoadBalancerControllerInput) *LoadBalancerController + func (lbc *LoadBalancerController) AddSyncQueue(item interface{}) + func (lbc *LoadBalancerController) HasCorrectIngressClass(obj interface{}) bool + func (lbc *LoadBalancerController) IsExternalServiceForStatus(svc *api_v1.Service) bool + func (lbc *LoadBalancerController) IsExternalServiceKeyForStatus(key string) bool + func (lbc *LoadBalancerController) IsNginxReady() bool + func (lbc *LoadBalancerController) Run() + func (lbc *LoadBalancerController) Stop() + func (lbc *LoadBalancerController) UpdateIngressStatusAndEventsOnDelete(ingConfig *IngressConfiguration, changeError string, deleteErr error) + func (lbc *LoadBalancerController) UpdateVirtualServerStatusAndEventsOnDelete(vsConfig *VirtualServerConfiguration, changeError string, deleteErr error) + type MinionConfiguration struct + Ingress *networking.Ingress + ValidPaths map[string]bool + func NewMinionConfiguration(ing *networking.Ingress) *MinionConfiguration + type NewLoadBalancerControllerInput struct + AppProtectDosEnabled bool + AppProtectEnabled bool + AreCustomResourcesEnabled bool + CertManagerEnabled bool + ConfClient k8s_nginx.Interface + ConfigMaps string + ControllerNamespace string + DefaultServerSecret string + DynClient dynamic.Interface + EnableOIDC bool + ExternalDNSEnabled bool + ExternalServiceName string + GlobalConfiguration string + GlobalConfigurationValidator *validation.GlobalConfigurationValidator + IngressClass string + IngressLink string + InternalRoutesEnabled bool + IsIPV6Disabled bool + IsLatencyMetricsEnabled bool + IsLeaderElectionEnabled bool + IsNginxPlus bool + IsPrometheusEnabled bool + IsTLSPassthroughEnabled bool + KubeClient kubernetes.Interface + LeaderElectionLockName string + MetricsCollector collectors.ControllerCollector + Namespace []string + NginxConfigurator *configs.Configurator + ReportIngressStatus bool + RestConfig *rest.Config + ResyncPeriod time.Duration + SecretNamespace []string + SnippetsEnabled bool + SpireAgentAddress string + TLSPassthroughPort int + TransportServerValidator *validation.TransportServerValidator + VirtualServerValidator *validation.VirtualServerValidator + WatchNamespaceLabel string + WildcardTLSSecret string + type Operation int + const AddOrUpdate + const Delete + type Resource interface + AddWarning func(warning string) + GetKeyWithKind func() string + GetObjectMeta func() *metav1.ObjectMeta + IsEqual func(resource Resource) bool + Wins func(resource Resource) bool + type ResourceChange struct + Error string + Op Operation + Resource Resource + type TransportServerConfiguration struct + ListenerPort int + TransportServer *conf_v1.TransportServer + Warnings []string + func NewTransportServerConfiguration(ts *conf_v1.TransportServer) *TransportServerConfiguration + func (tsc *TransportServerConfiguration) AddWarning(warning string) + func (tsc *TransportServerConfiguration) GetKeyWithKind() string + func (tsc *TransportServerConfiguration) GetObjectMeta() *metav1.ObjectMeta + func (tsc *TransportServerConfiguration) IsEqual(resource Resource) bool + func (tsc *TransportServerConfiguration) Wins(resource Resource) bool + type TransportServerMetrics struct + TotalTCP int + TotalTLSPassthrough int + TotalUDP int + type VirtualServerConfiguration struct + HTTPPort int + HTTPSPort int + VirtualServer *conf_v1.VirtualServer + VirtualServerRoutes []*conf_v1.VirtualServerRoute + Warnings []string + func NewVirtualServerConfiguration(vs *conf_v1.VirtualServer, vsrs []*conf_v1.VirtualServerRoute, ...) *VirtualServerConfiguration + func (vsc *VirtualServerConfiguration) AddWarning(warning string) + func (vsc *VirtualServerConfiguration) GetKeyWithKind() string + func (vsc *VirtualServerConfiguration) GetObjectMeta() *metav1.ObjectMeta + func (vsc *VirtualServerConfiguration) IsEqual(resource Resource) bool + func (vsc *VirtualServerConfiguration) Wins(resource Resource) bool Other modules containing this package github.com/jjngx/kubernetes-ingress
Go to main page