k8s

package

Go to main page

Versions in this module

v1

v1.12.5

Oct 19, 2022

v1.12.4

Mar 24, 2022

v1.12.3

Oct 28, 2021

Changes in this version

type NewLoadBalancerControllerInput

+ SnippetsEnabled bool

v1.12.2

Oct 7, 2021

v1.12.1

Sep 8, 2021

v1.12.0

Jun 30, 2021

v1.11.3

May 25, 2021

v1.11.2

May 19, 2021

v1.11.1

Apr 8, 2021

v1.11.0

Mar 31, 2021

Changes in this version

type Configuration

+ func (c *Configuration) AddOrUpdateGlobalConfiguration(gc *conf_v1alpha1.GlobalConfiguration) ([]ResourceChange, []ConfigurationProblem, error)

+ func (c *Configuration) AddOrUpdateTransportServer(ts *conf_v1alpha1.TransportServer) ([]ResourceChange, []ConfigurationProblem)

+ func (c *Configuration) DeleteGlobalConfiguration() ([]ResourceChange, []ConfigurationProblem)

+ func (c *Configuration) DeleteTransportServer(key string) ([]ResourceChange, []ConfigurationProblem)

+ func (c *Configuration) FindResourcesForAppProtectLogConfAnnotation(logConfNamespace string, logConfName string) []Resource

+ func (c *Configuration) FindResourcesForAppProtectPolicyAnnotation(policyNamespace string, policyName string) []Resource

type NewLoadBalancerControllerInput

+ IsTLSPassthroughEnabled bool

+ type TransportServerConfiguration struct

+ ListenerPort int

+ TransportServer *conf_v1alpha1.TransportServer

+ Warnings []string

+ func NewTransportServerConfiguration(ts *conf_v1alpha1.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

v1.10.1

Mar 16, 2021

v1.10.0

Jan 26, 2021

Changes in this version

+ type AppProtectChange struct

+ Op Operation

+ Resource interface{}

+ type AppProtectConfiguration struct

+ LogConfs map[string]*AppProtectLogConfEx

+ Policies map[string]*AppProtectPolicyEx

+ UserSigs map[string]*AppProtectUserSigEx

+ func NewAppProtectConfiguration() *AppProtectConfiguration

+ func (apc *AppProtectConfiguration) AddOrUpdateLogConf(logconfObj *unstructured.Unstructured) (changes []AppProtectChange, problems []AppProtectProblem)

+ func (apc *AppProtectConfiguration) AddOrUpdatePolicy(policyObj *unstructured.Unstructured) (changes []AppProtectChange, problems []AppProtectProblem)

+ func (apc *AppProtectConfiguration) AddOrUpdateUserSig(userSigObj *unstructured.Unstructured) (change AppProtectUserSigChange, problems []AppProtectProblem)

+ func (apc *AppProtectConfiguration) DeleteLogConf(key string) (changes []AppProtectChange, problems []AppProtectProblem)

+ func (apc *AppProtectConfiguration) DeletePolicy(key string) (changes []AppProtectChange, problems []AppProtectProblem)

+ func (apc *AppProtectConfiguration) DeleteUserSig(key string) (change AppProtectUserSigChange, problems []AppProtectProblem)

+ func (apc *AppProtectConfiguration) GetAppResource(kind, key string) (*unstructured.Unstructured, error)

+ type AppProtectLogConfEx struct

+ ErrorMsg string

+ IsValid bool

+ Obj *unstructured.Unstructured

+ type AppProtectPolicyEx struct

+ ErrorMsg string

+ IsValid bool

+ Obj *unstructured.Unstructured

+ SignatureReqs []SignatureReq

+ type AppProtectProblem struct

+ Message string

+ Object *unstructured.Unstructured

+ Reason string

+ type AppProtectUserSigChange struct

+ PolicyAddsOrUpdates []*unstructured.Unstructured

+ PolicyDeletions []*unstructured.Unstructured

+ UserSigs []*unstructured.Unstructured

+ type AppProtectUserSigEx struct

+ ErrorMsg string

+ IsValid bool

+ Obj *unstructured.Unstructured

+ RevTime *time.Time

+ Tag 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) AcquireHost(host string)

+ 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) ReleaseHost(host string)

+ func (ic *IngressConfiguration) Wins(resource Resource) bool

+ type MinionConfiguration struct

+ Ingress *networking.Ingress

+ ValidPaths map[string]bool

+ func NewMinionConfiguration(ing *networking.Ingress) *MinionConfiguration

type NewLoadBalancerControllerInput

+ EnablePreviewPolicies bool

+ IngressLink string

+ IsPrometheusEnabled bool

+ type RevTimes struct

+ MaxRevTime *time.Time

+ MinRevTime *time.Time

+ type SignatureReq struct

+ RevTimes *RevTimes

+ Tag string

+ type VirtualServerConfiguration struct

+ VirtualServer *conf_v1.VirtualServer

+ VirtualServerRoutes []*conf_v1.VirtualServerRoute

+ Warnings []string

+ func NewVirtualServerConfiguration(vs *conf_v1.VirtualServer, vsrs []*conf_v1.VirtualServerRoute, ...) *VirtualServerConfiguration

+ func (vsc *VirtualServerConfiguration) AcquireHost(host string)

+ 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) ReleaseHost(host string)

+ func (vsc *VirtualServerConfiguration) Wins(resource Resource) bool

v1.9.1

Nov 23, 2020

v1.9.0

Oct 20, 2020

Changes in this version

+ const CA

+ const CAKey

+ const IngressControllerName

+ func GetK8sVersion(client kubernetes.Interface) (v *version.Version, err error)

+ func ValidateCASecret(secret *v1.Secret) error

+ type Configuration struct

+ func NewConfiguration(hasCorrectIngressClass func(interface{}) bool, isPlus bool, ...) *Configuration

+ func (c *Configuration) AddOrUpdateIngress(ing *networking.Ingress) ([]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) DeleteIngress(key string) ([]ResourceChange, []ConfigurationProblem)

+ func (c *Configuration) DeleteVirtualServer(key string) ([]ResourceChange, []ConfigurationProblem)

+ func (c *Configuration) DeleteVirtualServerRoute(key string) ([]ResourceChange, []ConfigurationProblem)

+ func (c *Configuration) FindResourcesForAppProtectLogConf(logConfNamespace string, logConfName string) []Resource

+ func (c *Configuration) FindResourcesForAppProtectPolicy(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) GetResources() []Resource

+ func (c *Configuration) GetResourcesWithFilter(filter resourceFilter) []Resource

+ type ConfigurationProblem struct

+ IsError bool

+ Message string

+ Object runtime.Object

+ Reason string

+ type FullIngress struct

+ ChildWarnings map[string][]string

+ Ingress *networking.Ingress

+ IsMaster bool

+ Minions []*FullMinion

+ ValidHosts map[string]bool

+ Warnings []string

+ func NewMasterFullIngress(ing *networking.Ingress, minions []*FullMinion, ...) *FullIngress

+ func NewRegularFullIngress(ing *networking.Ingress) *FullIngress

+ func (fi *FullIngress) AcquireHost(host string)

+ func (fi *FullIngress) AddWarning(warning string)

+ func (fi *FullIngress) GetKeyWithKind() string

+ func (fi *FullIngress) GetObjectMeta() *metav1.ObjectMeta

+ func (fi *FullIngress) IsEqual(resource Resource) bool

+ func (fi *FullIngress) ReleaseHost(host string)

+ func (fi *FullIngress) Wins(resource Resource) bool

+ type FullMinion struct

+ Ingress *networking.Ingress

+ ValidPaths map[string]bool

+ func NewFullMinion(ing *networking.Ingress) *FullMinion

+ type FullVirtualServer struct

+ VirtualServer *conf_v1.VirtualServer

+ VirtualServerRoutes []*conf_v1.VirtualServerRoute

+ Warnings []string

+ func NewFullVirtualServer(vs *conf_v1.VirtualServer, vsrs []*conf_v1.VirtualServerRoute, ...) *FullVirtualServer

+ func (fvs *FullVirtualServer) AcquireHost(host string)

+ func (fvs *FullVirtualServer) AddWarning(warning string)

+ func (fvs *FullVirtualServer) GetKeyWithKind() string

+ func (fvs *FullVirtualServer) GetObjectMeta() *metav1.ObjectMeta

+ func (fvs *FullVirtualServer) IsEqual(resource Resource) bool

+ func (fvs *FullVirtualServer) ReleaseHost(host string)

+ func (fvs *FullVirtualServer) Wins(resource Resource) bool

type LoadBalancerController

+ func (lbc *LoadBalancerController) IsExternalServiceKeyForStatus(key string) bool

+ func (lbc *LoadBalancerController) UpdateIngressStatusAndEventsOnDelete(fullIng *FullIngress, changeError string, deleteErr error)

+ func (lbc *LoadBalancerController) UpdateVirtualServerStatusAndEventsOnDelete(fullVS *FullVirtualServer, changeError string, deleteErr error)

type NewLoadBalancerControllerInput

+ InternalRoutesEnabled bool

+ IsLatencyMetricsEnabled bool

+ VirtualServerValidator *validation.VirtualServerValidator

+ type Operation int

+ const AddOrUpdate

+ const Delete

+ type Resource interface

+ AcquireHost func(host string)

+ AddWarning func(warning string)

+ GetKeyWithKind func() string

+ GetObjectMeta func() *metav1.ObjectMeta

+ IsEqual func(resource Resource) bool

+ ReleaseHost func(host string)

+ Wins func(resource Resource) bool

+ type ResourceChange struct

+ Error string

+ Op Operation

+ Resource Resource

v1.9.0-nsmready

Sep 21, 2020

v1.8.1

Aug 18, 2020

v1.8.0

Jul 23, 2020

Changes in this version

+ func ParseResourceReferenceAnnotation(ns, antn string) string

+ func ValidateAppProtectLogConf(logConf *unstructured.Unstructured) error

+ func ValidateAppProtectLogDestinationAnnotation(dstAntn string) error

+ func ValidateAppProtectPolicy(policy *unstructured.Unstructured) error

type LoadBalancerController

+ func (lbc *LoadBalancerController) HasCorrectIngressClass(obj interface{}) bool

+ func (lbc *LoadBalancerController) IsNginxReady() bool

type NewLoadBalancerControllerInput

+ AppProtectEnabled bool

+ DynClient dynamic.Interface

v1.7.2

Jun 25, 2020

v1.7.1

Jun 3, 2020

Changes in this version

+ func NewSpiffeController(sync func(*workload.X509SVIDs), spireAgentAddr string) (*spiffeController, error)

type NewLoadBalancerControllerInput

+ SpireAgentAddress string

v1.7.0

Apr 29, 2020

Changes in this version

type LoadBalancerController

+ func (lbc *LoadBalancerController) EnqueueTransportServerForService(service *api_v1.Service)

type NewLoadBalancerControllerInput

+ GlobalConfiguration string

+ GlobalConfigurationValidator *validation.GlobalConfigurationValidator

+ TransportServerValidator *validation.TransportServerValidator

v1.7.0-rc1

Mar 31, 2020

v1.6.3

Mar 6, 2020

v1.6.2

Feb 6, 2020

v1.6.1

Jan 14, 2020

v1.6.0

Dec 19, 2019

v1.5.8

Nov 26, 2019

v1.5.7

Oct 25, 2019

v1.5.6

Sep 25, 2019

v1.5.5

Sep 4, 2019

v1.5.4

Aug 21, 2019

v1.5.3

Aug 7, 2019

v1.5.2

Jul 31, 2019

v1.5.1

Jul 3, 2019

v1.5.0

May 16, 2019

Changes in this version

+ const JWK

+ const JWTKeyKey

+ const TLS

+ func GetSecretKind(secret *v1.Secret) (int, error)

+ func ParseNamespaceName(value string) (ns string, name string, err error)

+ func ValidateJWKSecret(secret *v1.Secret) error

+ func ValidateTLSSecret(secret *v1.Secret) error

+ type LoadBalancerController struct

+ func NewLoadBalancerController(input NewLoadBalancerControllerInput) *LoadBalancerController

+ func (lbc *LoadBalancerController) AddSyncQueue(item interface{})

+ func (lbc *LoadBalancerController) EnqueueIngressForService(svc *api_v1.Service)

+ func (lbc *LoadBalancerController) EnqueueVirtualServersForService(service *api_v1.Service)

+ func (lbc *LoadBalancerController) FindMasterForMinion(minion *extensions.Ingress) (*extensions.Ingress, error)

+ func (lbc *LoadBalancerController) GetManagedIngresses() ([]extensions.Ingress, map[string]*configs.MergeableIngresses)

+ func (lbc *LoadBalancerController) IsExternalServiceForStatus(svc *api_v1.Service) bool

+ func (lbc *LoadBalancerController) IsNginxIngress(ing *extensions.Ingress) bool

+ func (lbc *LoadBalancerController) Run()

+ func (lbc *LoadBalancerController) Stop()

+ func (lbc *LoadBalancerController) UpdateManagedAndMergeableIngresses(ingresses []v1beta1.Ingress, ...) error

+ func (lbc *LoadBalancerController) ValidateSecret(secret *api_v1.Secret) error

+ type NewLoadBalancerControllerInput struct

+ AreCustomResourcesEnabled bool

+ ConfClient k8s_nginx.Interface

+ ConfigMaps string

+ ControllerNamespace string

+ DefaultServerSecret string

+ ExternalServiceName string

+ IngressClass string

+ IsLeaderElectionEnabled bool

+ IsNginxPlus bool

+ KubeClient kubernetes.Interface

+ LeaderElectionLockName string

+ MetricsCollector collectors.ControllerCollector

+ Namespace string

+ NginxConfigurator *configs.Configurator

+ ReportIngressStatus bool

+ ResyncPeriod time.Duration

+ UseIngressClassOnly bool

+ WildcardTLSSecret string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL