AddCSRWatchWithRelevancyFn adds a watch for CSRs with the given label.

AddNamespacedWatch creates a watch on the given object.

AddNodeLocalDNSWatch creates a watch on the node-local-dns pods.

AddSecretWatchWithLabel adds a secret watch for secrets with the given label in the given namespace.

AddTigeraStatusWatch creates a watch on the given object.

ApplyDefaults sets any defaults that haven't been set on the given object and writes it to the k8s server.

ContextLoggerForResource provides a logger instance with context set for the provided object.

ElasticsearchSecrets gets the secrets needed for a component to be able to access Elasticsearch.

FetchLicenseKey returns the license if it has been installed.

GetAPIServer finds the correct API server instance and returns a message and error in the case of an error.

Return the AplicationLayer CR if present.

GetAuthentication finds the authentication CR in your cluster.

GetDNSServiceName returns the name and namespace for the DNS service based on the given provider.

GetElasticLicenseType returns the license type from elastic-licensing ConfigMap that ECK operator keeps updated.

GetElasticsearchClusterConfig retrieves the config map containing the elasticsearch configuration values, such as the the cluster name and replica count.

GetIDPSecret retrieves the Secret containing sensitive information for the configuration IdP specified in the given operatorv1.Authentication CR.

GetInstallation returns the current installation, for use by other controllers.

GetInstallationStatus returns the current installation status, for use by other controllers.

GetK8sServiceEndPoint returns the kubernetes-service-endpoint configmap.

GetKeyValidatorConfig uses the operatorv1.Authentication CR given to create the KeyValidatorConfig.

GetKubeControllerMetricsPort fetches kube controller metrics port.

Return the ManagementCluster CR if present.

Return the ManagementClusterConnection CR if present.

GetNonClusterHost finds the NonClusterHost CR in your cluster.

GetPacketCapture finds the PacketCapture CR in your cluster.

GetTenant returns the Tenant instance in the given namespace.

IgnoreObject returns true if the object has been marked as ignored by the user, and returns false otherwise.

IsFeatureActive return true if the feature is listed in LicenseStatusKey.

MonitorConfigMap starts a goroutine which exits if the given configmap's data is changed.

cr is allowed to be nil in the case we don't want to put ownership on a resource, this is useful for CRD management so that they are not removed automatically.

PopulateK8sServiceEndPoint reads the kubernetes-service-endpoint configmap and pushes KUBERNETES_SERVICE_HOST, KUBERNETES_SERVICE_PORT to calico-node daemonset, typha apiserver deployments.

RequiresTigeraSecure determines if the configuration requires we start the tigera secure controllers.

StrToElasticLicenseType maps Elasticsearch license to one of the known and expected value.

TenantNamespaces returns all namespaces that contain a tenant.

UseExternalElastic returns true if this cluster is configured to use an external elasticsearch cluster, and false otherwise.

ValidateCertPair checks if the given secret exists in the given namespace and if so that it contains key and cert fields.

ValidateResourceNameIsQualified returns a compiled list of errors which states which rule the name did not respect.

WaitToAddResourceWatch will check if projectcalico.org APIs are available and if so, it will add a watch for resource The completion of this operation will be signaled on a ready channel.

AllowedSysctlKeys controls the allowed Sysctl keys can be set in Tuning plugin.

User's name in ES.

User's name in ES.

StandardRetry is the amount of time to wait beofre retrying a request in most scenarios.

ReadyFlag is used to synchronize access to a boolean flag flag that can be shared between go routines.

Role represents an Elasticsearch role that may be attached to a User.

User represents an Elasticsearch user, which may or may not have roles attached to it.