Versions in this module Expand all Collapse all v0 v0.28.2 Mar 24, 2025 Changes in this version + const BootstrapTokenHashAnnotation + const BootstrapTokenSecretHashedTokenName + const BootstrapTokenSecretSecretName + const ElasticPort + const ElasticPortName + const ExtraKafkaPropertiesFilename + const HumioContainerName + const HumioDataPath + const HumioDataVolumeName + const HumioPort + const HumioPortName + const HumioServiceAccountNameSuffix + const HumioVersionMinimumSupported + const InitContainerName + const MaximumMinReadyRequeue + const NodePoolFeatureAllowedAPIRequestType + const PodConditionReasonUnschedulable + const PodHashAnnotation + const PodRevisionAnnotation + const RolePermissionsFilename + const ViewGroupPermissionsFilename + func AppendEnvVarToEnvVarsIfNotAlreadyPresent(envVars []corev1.EnvVar, defaultEnvVar corev1.EnvVar) []corev1.EnvVar + func ConstructContainerArgs(hnp *HumioNodePool, podEnvVars []corev1.EnvVar) ([]string, error) + func ConstructESIngestIngress(hc *humiov1alpha1.HumioCluster, esHostname string) *networkingv1.Ingress + func ConstructGeneralIngress(hc *humiov1alpha1.HumioCluster, hostname string) *networkingv1.Ingress + func ConstructIngestIngress(hc *humiov1alpha1.HumioCluster, hostname string) *networkingv1.Ingress + func ConstructNodeCertificate(hnp *HumioNodePool, nodeSuffix string) cmapi.Certificate + func ConstructPod(hnp *HumioNodePool, humioNodeName string, attachments *podAttachments) (*corev1.Pod, error) + func ConstructService(hnp *HumioNodePool) *corev1.Service + func ConstructStreamingQueryIngress(hc *humiov1alpha1.HumioCluster, hostname string) *networkingv1.Ingress + func EnvVarHasKey(envVars []corev1.EnvVar, key string) bool + func EnvVarHasValue(envVars []corev1.EnvVar, key string, value string) bool + func EnvVarValue(envVars []corev1.EnvVar, key string) string + func FilterPodsByZoneName(ctx context.Context, c client.Client, podList []corev1.Pod, zoneName string) ([]corev1.Pod, error) + func FilterPodsExcludePodsWithEmptyNodeName(podList []corev1.Pod) []corev1.Pod + func FilterPodsExcludePodsWithPodRevisionOrPodHash(podList []corev1.Pod, podRevisionToExclude int, podHashToExclude string) []corev1.Pod + func FindNextAvailablePvc(pvcList []corev1.PersistentVolumeClaim, podList []corev1.Pod, ...) (string, error) + func FindPvcForPod(pvcList []corev1.PersistentVolumeClaim, pod corev1.Pod) (corev1.PersistentVolumeClaim, error) + func GetDesiredCertHash(hnp *HumioNodePool) string + func GetKeyWithHighestValue[K comparable, V constraints.Ordered](inputMap map[K]V) (K, error) + func GetPodNameFromNodeUri(uri string) (string, error) + func NewPodLifecycleState(hnp HumioNodePool) *podLifecycleState + func NodePoolFilterDoesNotHaveNodes(nodePool *HumioNodePool) bool + func NodePoolFilterHasNode(nodePool *HumioNodePool) bool + func RemoveIntFromSlice(slice []int, value int) []int + type CACert struct + Certificate []byte + Key []byte + type HumioActionReconciler struct + BaseLogger logr.Logger + HumioClient humio.Client + Log logr.Logger + Namespace string + func (r *HumioActionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *HumioActionReconciler) SetupWithManager(mgr ctrl.Manager) error + type HumioAggregateAlertReconciler struct + BaseLogger logr.Logger + HumioClient humio.Client + Log logr.Logger + Namespace string + func (r *HumioAggregateAlertReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *HumioAggregateAlertReconciler) SetupWithManager(mgr ctrl.Manager) error + type HumioAlertReconciler struct + BaseLogger logr.Logger + HumioClient humio.Client + Log logr.Logger + Namespace string + func (r *HumioAlertReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *HumioAlertReconciler) SetupWithManager(mgr ctrl.Manager) error + type HumioBootstrapTokenConfig struct + BootstrapToken *humiov1alpha1.HumioBootstrapToken + ManagedHumioCluster *humiov1alpha1.HumioCluster + func NewHumioBootstrapTokenConfig(bootstrapToken *humiov1alpha1.HumioBootstrapToken, ...) HumioBootstrapTokenConfig + type HumioBootstrapTokenReconciler struct + BaseLogger logr.Logger + Log logr.Logger + Namespace string + func (r *HumioBootstrapTokenReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *HumioBootstrapTokenReconciler) SetupWithManager(mgr ctrl.Manager) error + type HumioBootstrapTokenSecretData struct + HashedToken string + Secret string + type HumioClusterReconciler struct + BaseLogger logr.Logger + HumioClient humio.Client + Log logr.Logger + Namespace string + func (r *HumioClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *HumioClusterReconciler) SetupWithManager(mgr ctrl.Manager) error + type HumioExternalClusterReconciler struct + BaseLogger logr.Logger + HumioClient humio.Client + Log logr.Logger + Namespace string + func (r *HumioExternalClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *HumioExternalClusterReconciler) SetupWithManager(mgr ctrl.Manager) error + type HumioFilterAlertReconciler struct + BaseLogger logr.Logger + HumioClient humio.Client + Log logr.Logger + Namespace string + func (r *HumioFilterAlertReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *HumioFilterAlertReconciler) SetupWithManager(mgr ctrl.Manager) error + type HumioIngestTokenReconciler struct + BaseLogger logr.Logger + HumioClient humio.Client + Log logr.Logger + Namespace string + func (r *HumioIngestTokenReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *HumioIngestTokenReconciler) SetupWithManager(mgr ctrl.Manager) error + type HumioNodePool struct + func NewHumioNodeManagerFromHumioCluster(hc *humiov1alpha1.HumioCluster) *HumioNodePool + func NewHumioNodeManagerFromHumioNodePool(hc *humiov1alpha1.HumioCluster, hnp *humiov1alpha1.HumioNodePoolSpec) *HumioNodePool + func (hnp *HumioNodePool) DataVolumePersistentVolumeClaimSpecTemplateIsSetByUser() bool + func (hnp *HumioNodePool) GetAffinity() *corev1.Affinity + func (hnp *HumioNodePool) GetClusterName() string + func (hnp *HumioNodePool) GetCommonClusterLabels() map[string]string + func (hnp *HumioNodePool) GetContainerLivenessProbe() *corev1.Probe + func (hnp *HumioNodePool) GetContainerReadinessProbe() *corev1.Probe + func (hnp *HumioNodePool) GetContainerSecurityContext() *corev1.SecurityContext + func (hnp *HumioNodePool) GetContainerStartupProbe() *corev1.Probe + func (hnp *HumioNodePool) GetDataVolumePersistentVolumeClaimPolicy() humiov1alpha1.HumioPersistentVolumeClaimPolicy + func (hnp *HumioNodePool) GetDataVolumePersistentVolumeClaimSpecTemplate(pvcName string) corev1.VolumeSource + func (hnp *HumioNodePool) GetDataVolumePersistentVolumeClaimSpecTemplateRAW() corev1.PersistentVolumeClaimSpec + func (hnp *HumioNodePool) GetDataVolumeSource() corev1.VolumeSource + func (hnp *HumioNodePool) GetDesiredBootstrapTokenHash() string + func (hnp *HumioNodePool) GetDesiredPodHash() string + func (hnp *HumioNodePool) GetDesiredPodRevision() int + func (hnp *HumioNodePool) GetDigestPartitionsCount() int + func (hnp *HumioNodePool) GetEnvironmentVariables() []corev1.EnvVar + func (hnp *HumioNodePool) GetEnvironmentVariablesSource() []corev1.EnvFromSource + func (hnp *HumioNodePool) GetExtraHumioVolumeMounts() []corev1.VolumeMount + func (hnp *HumioNodePool) GetExtraKafkaConfigs() string + func (hnp *HumioNodePool) GetExtraKafkaConfigsConfigMapName() string + func (hnp *HumioNodePool) GetExtraVolumes() []corev1.Volume + func (hnp *HumioNodePool) GetHelperImage() string + func (hnp *HumioNodePool) GetHostname() string + func (hnp *HumioNodePool) GetHumioESServicePort() int32 + func (hnp *HumioNodePool) GetHumioServiceAccountAnnotations() map[string]string + func (hnp *HumioNodePool) GetHumioServiceAccountName() string + func (hnp *HumioNodePool) GetHumioServiceAnnotations() map[string]string + func (hnp *HumioNodePool) GetHumioServiceLabels() map[string]string + func (hnp *HumioNodePool) GetHumioServicePort() int32 + func (hnp *HumioNodePool) GetIDPCertificateSecretName() string + func (hnp *HumioNodePool) GetImage() string + func (hnp *HumioNodePool) GetImagePullPolicy() corev1.PullPolicy + func (hnp *HumioNodePool) GetImagePullSecrets() []corev1.LocalObjectReference + func (hnp *HumioNodePool) GetImageSource() *humiov1alpha1.HumioImageSource + func (hnp *HumioNodePool) GetIngress() humiov1alpha1.HumioClusterIngressSpec + func (hnp *HumioNodePool) GetInitClusterRoleBindingName() string + func (hnp *HumioNodePool) GetInitClusterRoleName() string + func (hnp *HumioNodePool) GetInitServiceAccountName() string + func (hnp *HumioNodePool) GetLabelsForSecret(secretName string) map[string]string + func (hnp *HumioNodePool) GetNamespace() string + func (hnp *HumioNodePool) GetNodeCount() int + func (hnp *HumioNodePool) GetNodePoolFeatureAllowedAPIRequestTypes() []string + func (hnp *HumioNodePool) GetNodePoolLabels() map[string]string + func (hnp *HumioNodePool) GetNodePoolName() string + func (hnp *HumioNodePool) GetPath() string + func (hnp *HumioNodePool) GetPodAnnotations() map[string]string + func (hnp *HumioNodePool) GetPodDisruptionBudget() *humiov1alpha1.HumioPodDisruptionBudgetSpec + func (hnp *HumioNodePool) GetPodDisruptionBudgetName() string + func (hnp *HumioNodePool) GetPodLabels() map[string]string + func (hnp *HumioNodePool) GetPodSecurityContext() *corev1.PodSecurityContext + func (hnp *HumioNodePool) GetPriorityClassName() string + func (hnp *HumioNodePool) GetProbeScheme() corev1.URIScheme + func (hnp *HumioNodePool) GetResources() corev1.ResourceRequirements + func (hnp *HumioNodePool) GetRolePermissions() string + func (hnp *HumioNodePool) GetRolePermissionsConfigMapName() string + func (hnp *HumioNodePool) GetServiceName() string + func (hnp *HumioNodePool) GetServiceType() corev1.ServiceType + func (hnp *HumioNodePool) GetShareProcessNamespace() *bool + func (hnp *HumioNodePool) GetSidecarContainers() []corev1.Container + func (hnp *HumioNodePool) GetState() string + func (hnp *HumioNodePool) GetTLSSpec() *humiov1alpha1.HumioClusterTLSSpec + func (hnp *HumioNodePool) GetTargetReplicationFactor() int + func (hnp *HumioNodePool) GetTerminationGracePeriodSeconds() *int64 + func (hnp *HumioNodePool) GetTolerations() []corev1.Toleration + func (hnp *HumioNodePool) GetTopologySpreadConstraints() []corev1.TopologySpreadConstraint + func (hnp *HumioNodePool) GetUpdateStrategy() *humiov1alpha1.HumioUpdateStrategy + func (hnp *HumioNodePool) GetViewGroupPermissions() string + func (hnp *HumioNodePool) GetViewGroupPermissionsConfigMapName() string + func (hnp *HumioNodePool) GetZoneUnderMaintenance() string + func (hnp *HumioNodePool) HumioServiceAccountIsSetByUser() bool + func (hnp *HumioNodePool) InitContainerDisabled() bool + func (hnp *HumioNodePool) InitServiceAccountIsSetByUser() bool + func (hnp *HumioNodePool) IsDownscalingFeatureEnabled() bool + func (hnp *HumioNodePool) OkToDeletePvc() bool + func (hnp *HumioNodePool) PVCsEnabled() bool + func (hnp *HumioNodePool) SetImage(image string) + func (hnp *HumioNodePool) TLSEnabled() bool + func (hnp HumioNodePool) GetBootstrapTokenName() string + func (hnp HumioNodePool) GetInitServiceAccountSecretName() string + type HumioNodePoolList struct + Items []*HumioNodePool + func (n *HumioNodePoolList) Add(hnp *HumioNodePool) + func (n *HumioNodePoolList) Filter(f func(*HumioNodePool) bool) []*HumioNodePool + type HumioParserReconciler struct + BaseLogger logr.Logger + HumioClient humio.Client + Log logr.Logger + Namespace string + func (r *HumioParserReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *HumioParserReconciler) SetupWithManager(mgr ctrl.Manager) error + type HumioRepositoryReconciler struct + BaseLogger logr.Logger + HumioClient humio.Client + Log logr.Logger + Namespace string + func (r *HumioRepositoryReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *HumioRepositoryReconciler) SetupWithManager(mgr ctrl.Manager) error + type HumioScheduledSearchReconciler struct + BaseLogger logr.Logger + HumioClient humio.Client + Log logr.Logger + Namespace string + func (r *HumioScheduledSearchReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *HumioScheduledSearchReconciler) SetupWithManager(mgr ctrl.Manager) error + type HumioVersion struct + func HumioVersionFromString(image string) *HumioVersion + func (hv *HumioVersion) AtLeast(version string) (bool, error) + func (hv *HumioVersion) IsLatest() bool + func (hv *HumioVersion) SemVer() *semver.Version + func (hv *HumioVersion) String() string + type HumioViewReconciler struct + BaseLogger logr.Logger + HumioClient humio.Client + Log logr.Logger + Namespace string + func (r *HumioViewReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *HumioViewReconciler) SetupWithManager(mgr ctrl.Manager) error + type Option interface + Apply func(hc *humiov1alpha1.HumioCluster) + GetResult func() (reconcile.Result, error) + type StatusOptions interface + Get func() []Option