controller

package
v0.28.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 24, 2025 License: Apache-2.0 Imports: 52 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// BootstrapTokenSecretHashedTokenName is the name of the hashed token key inside the bootstrap token secret
	BootstrapTokenSecretHashedTokenName = "hashedToken"
	// BootstrapTokenSecretSecretName is the name of the secret key inside the bootstrap token secret
	BootstrapTokenSecretSecretName = "secret"
)
View Source 
const (

	// Set on Pod objects
	PodHashAnnotation            = "humio.com/pod-hash"
	PodRevisionAnnotation        = "humio.com/pod-revision"
	BootstrapTokenHashAnnotation = "humio.com/bootstrap-token-hash" // #nosec G101

)
View Source 
const (
	HumioPortName   = "http"
	HumioPort       = 8080
	ElasticPortName = "es"
	ElasticPort     = 9200

	ExtraKafkaPropertiesFilename = "extra-kafka-properties.properties"
	ViewGroupPermissionsFilename = "view-group-permissions.json"
	RolePermissionsFilename      = "role-permissions.json"
	HumioContainerName           = "humio"
	InitContainerName            = "humio-init"

	// namespaced resources:
	HumioServiceAccountNameSuffix = "humio"

	// nodepool internal
	NodePoolFeatureAllowedAPIRequestType = "OperatorInternal"
)
View Source 
const (
	HumioDataPath       = "/data/humio-data"
	HumioDataVolumeName = "humio-data"
)
View Source 
const (
	HumioVersionMinimumSupported = "1.130.0"
)
View Source 
const (
	// MaximumMinReadyRequeue The maximum requeue time to set for the MinReadySeconds functionality - this is to avoid a scenario where we
	// requeue for hours into the future.
	MaximumMinReadyRequeue = time.Second * 300
)
View Source 
const (
	PodConditionReasonUnschedulable = "Unschedulable"
)

Variables

This section is empty.

Functions

func AppendEnvVarToEnvVarsIfNotAlreadyPresent 

func AppendEnvVarToEnvVarsIfNotAlreadyPresent(envVars []corev1.EnvVar, defaultEnvVar corev1.EnvVar) []corev1.EnvVar

func ConstructContainerArgs 

func ConstructContainerArgs(hnp *HumioNodePool, podEnvVars []corev1.EnvVar) ([]string, error)

ConstructContainerArgs returns the container arguments for the Humio pods. We want to grab a UUID from zookeeper only when using ephemeral disks. If we're using persistent storage, then we rely on Humio to generate the UUID. Note that relying on PVCs may not be good enough here as it's possible to have persistent storage using hostPath. For this reason, we rely on the USING_EPHEMERAL_DISKS environment variable.

func ConstructESIngestIngress 

func ConstructESIngestIngress(hc *humiov1alpha1.HumioCluster, esHostname string) *networkingv1.Ingress

func ConstructGeneralIngress 

func ConstructGeneralIngress(hc *humiov1alpha1.HumioCluster, hostname string) *networkingv1.Ingress

func ConstructIngestIngress 

func ConstructIngestIngress(hc *humiov1alpha1.HumioCluster, hostname string) *networkingv1.Ingress

func ConstructNodeCertificate 

func ConstructNodeCertificate(hnp *HumioNodePool, nodeSuffix string) cmapi.Certificate

func ConstructPod 

func ConstructPod(hnp *HumioNodePool, humioNodeName string, attachments *podAttachments) (*corev1.Pod, error)

func ConstructService 

func ConstructService(hnp *HumioNodePool) *corev1.Service

func ConstructStreamingQueryIngress 

func ConstructStreamingQueryIngress(hc *humiov1alpha1.HumioCluster, hostname string) *networkingv1.Ingress

func EnvVarHasKey 

func EnvVarHasKey(envVars []corev1.EnvVar, key string) bool

func EnvVarHasValue 

func EnvVarHasValue(envVars []corev1.EnvVar, key string, value string) bool

func EnvVarValue 

func EnvVarValue(envVars []corev1.EnvVar, key string) string

EnvVarValue returns the value of the given environment variable if the environment variable is not preset, return empty string

func FilterPodsByZoneName 

func FilterPodsByZoneName(ctx context.Context, c client.Client, podList []corev1.Pod, zoneName string) ([]corev1.Pod, error)

func FilterPodsExcludePodsWithEmptyNodeName 

func FilterPodsExcludePodsWithEmptyNodeName(podList []corev1.Pod) []corev1.Pod

func FilterPodsExcludePodsWithPodRevisionOrPodHash 

func FilterPodsExcludePodsWithPodRevisionOrPodHash(podList []corev1.Pod, podRevisionToExclude int, podHashToExclude string) []corev1.Pod

func FindNextAvailablePvc 

func FindNextAvailablePvc(pvcList []corev1.PersistentVolumeClaim, podList []corev1.Pod, pvcClaimNamesInUse map[string]struct{}) (string, error)

func FindPvcForPod 

func FindPvcForPod(pvcList []corev1.PersistentVolumeClaim, pod corev1.Pod) (corev1.PersistentVolumeClaim, error)

func GetDesiredCertHash 

func GetDesiredCertHash(hnp *HumioNodePool) string

func GetKeyWithHighestValue 

func GetKeyWithHighestValue[K comparable, V constraints.Ordered](inputMap map[K]V) (K, error)

GetKeyWithHighestValue returns the key corresponding to the highest value in a map. In case multiple keys have the same value, the first key is returned.

An error is returned if the passed map is empty.

func GetPodNameFromNodeUri 

func GetPodNameFromNodeUri(uri string) (string, error)

GetPodNameFromNodeUri extracts and returns the pod name from a given URI string. This is done by extracting the hostname from the URI, splitting it against the "." string, and returning the first part.

Examples:

An error is returned in case the URI cannot be parsed, or if the hostname string split has 0 parts

func NewPodLifecycleState 

func NewPodLifecycleState(hnp HumioNodePool) *podLifecycleState

func NodePoolFilterDoesNotHaveNodes 

func NodePoolFilterDoesNotHaveNodes(nodePool *HumioNodePool) bool

func NodePoolFilterHasNode 

func NodePoolFilterHasNode(nodePool *HumioNodePool) bool

func RemoveIntFromSlice 

func RemoveIntFromSlice(slice []int, value int) []int

Types

type CACert 

type CACert struct {
	Certificate []byte
	Key         []byte
}

type HumioActionReconciler 

type HumioActionReconciler struct {
	client.Client
	BaseLogger  logr.Logger
	Log         logr.Logger
	HumioClient humio.Client
	Namespace   string
}

HumioActionReconciler reconciles a HumioAction object

func (*HumioActionReconciler) Reconcile 

func (r *HumioActionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HumioActionReconciler) SetupWithManager 

func (r *HumioActionReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type HumioAggregateAlertReconciler 

type HumioAggregateAlertReconciler struct {
	client.Client
	BaseLogger  logr.Logger
	Log         logr.Logger
	HumioClient humio.Client
	Namespace   string
}

HumioAggregateAlertReconciler reconciles a HumioAggregateAlert object

func (*HumioAggregateAlertReconciler) Reconcile 

func (r *HumioAggregateAlertReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HumioAggregateAlertReconciler) SetupWithManager 

func (r *HumioAggregateAlertReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type HumioAlertReconciler 

type HumioAlertReconciler struct {
	client.Client
	BaseLogger  logr.Logger
	Log         logr.Logger
	HumioClient humio.Client
	Namespace   string
}

HumioAlertReconciler reconciles a HumioAlert object

func (*HumioAlertReconciler) Reconcile 

func (r *HumioAlertReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HumioAlertReconciler) SetupWithManager 

func (r *HumioAlertReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type HumioBootstrapTokenConfig 

type HumioBootstrapTokenConfig struct {
	BootstrapToken      *humiov1alpha1.HumioBootstrapToken
	ManagedHumioCluster *humiov1alpha1.HumioCluster
}

func NewHumioBootstrapTokenConfig 

func NewHumioBootstrapTokenConfig(bootstrapToken *humiov1alpha1.HumioBootstrapToken, managedHumioCluster *humiov1alpha1.HumioCluster) HumioBootstrapTokenConfig

type HumioBootstrapTokenReconciler 

type HumioBootstrapTokenReconciler struct {
	client.Client
	BaseLogger logr.Logger
	Log        logr.Logger
	Namespace  string
}

HumioBootstrapTokenReconciler reconciles a HumioBootstrapToken object

func (*HumioBootstrapTokenReconciler) Reconcile 

func (r *HumioBootstrapTokenReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HumioBootstrapTokenReconciler) SetupWithManager 

func (r *HumioBootstrapTokenReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type HumioBootstrapTokenSecretData 

type HumioBootstrapTokenSecretData struct {
	Secret      string `json:"secret"`
	HashedToken string `json:"hashedToken"`
}

type HumioClusterReconciler 

type HumioClusterReconciler struct {
	client.Client
	BaseLogger  logr.Logger
	Log         logr.Logger
	HumioClient humio.Client
	Namespace   string
}

HumioClusterReconciler reconciles a HumioCluster object

func (*HumioClusterReconciler) Reconcile 

func (r *HumioClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

nolint:gocyclo

func (*HumioClusterReconciler) SetupWithManager 

func (r *HumioClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type HumioExternalClusterReconciler 

type HumioExternalClusterReconciler struct {
	client.Client
	BaseLogger  logr.Logger
	Log         logr.Logger
	HumioClient humio.Client
	Namespace   string
}

HumioExternalClusterReconciler reconciles a HumioExternalCluster object

func (*HumioExternalClusterReconciler) Reconcile 

func (r *HumioExternalClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HumioExternalClusterReconciler) SetupWithManager 

func (r *HumioExternalClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type HumioFilterAlertReconciler 

type HumioFilterAlertReconciler struct {
	client.Client
	BaseLogger  logr.Logger
	Log         logr.Logger
	HumioClient humio.Client
	Namespace   string
}

HumioFilterAlertReconciler reconciles a HumioFilterAlert object

func (*HumioFilterAlertReconciler) Reconcile 

func (r *HumioFilterAlertReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HumioFilterAlertReconciler) SetupWithManager 

func (r *HumioFilterAlertReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type HumioIngestTokenReconciler 

type HumioIngestTokenReconciler struct {
	client.Client
	BaseLogger  logr.Logger
	Log         logr.Logger
	HumioClient humio.Client
	Namespace   string
}

HumioIngestTokenReconciler reconciles a HumioIngestToken object

func (*HumioIngestTokenReconciler) Reconcile 

func (r *HumioIngestTokenReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HumioIngestTokenReconciler) SetupWithManager 

func (r *HumioIngestTokenReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type HumioNodePool 

type HumioNodePool struct {
	// contains filtered or unexported fields
}

func NewHumioNodeManagerFromHumioCluster 

func NewHumioNodeManagerFromHumioCluster(hc *humiov1alpha1.HumioCluster) *HumioNodePool

func NewHumioNodeManagerFromHumioNodePool 

func NewHumioNodeManagerFromHumioNodePool(hc *humiov1alpha1.HumioCluster, hnp *humiov1alpha1.HumioNodePoolSpec) *HumioNodePool

func (*HumioNodePool) DataVolumePersistentVolumeClaimSpecTemplateIsSetByUser 

func (hnp *HumioNodePool) DataVolumePersistentVolumeClaimSpecTemplateIsSetByUser() bool

func (*HumioNodePool) GetAffinity 

func (hnp *HumioNodePool) GetAffinity() *corev1.Affinity

func (HumioNodePool) GetBootstrapTokenName 

func (hnp HumioNodePool) GetBootstrapTokenName() string

func (*HumioNodePool) GetClusterName 

func (hnp *HumioNodePool) GetClusterName() string

func (*HumioNodePool) GetCommonClusterLabels 

func (hnp *HumioNodePool) GetCommonClusterLabels() map[string]string

func (*HumioNodePool) GetContainerLivenessProbe 

func (hnp *HumioNodePool) GetContainerLivenessProbe() *corev1.Probe

func (*HumioNodePool) GetContainerReadinessProbe 

func (hnp *HumioNodePool) GetContainerReadinessProbe() *corev1.Probe

func (*HumioNodePool) GetContainerSecurityContext 

func (hnp *HumioNodePool) GetContainerSecurityContext() *corev1.SecurityContext

func (*HumioNodePool) GetContainerStartupProbe 

func (hnp *HumioNodePool) GetContainerStartupProbe() *corev1.Probe

func (*HumioNodePool) GetDataVolumePersistentVolumeClaimPolicy 

func (hnp *HumioNodePool) GetDataVolumePersistentVolumeClaimPolicy() humiov1alpha1.HumioPersistentVolumeClaimPolicy

func (*HumioNodePool) GetDataVolumePersistentVolumeClaimSpecTemplate 

func (hnp *HumioNodePool) GetDataVolumePersistentVolumeClaimSpecTemplate(pvcName string) corev1.VolumeSource

func (*HumioNodePool) GetDataVolumePersistentVolumeClaimSpecTemplateRAW 

func (hnp *HumioNodePool) GetDataVolumePersistentVolumeClaimSpecTemplateRAW() corev1.PersistentVolumeClaimSpec

func (*HumioNodePool) GetDataVolumeSource 

func (hnp *HumioNodePool) GetDataVolumeSource() corev1.VolumeSource

func (*HumioNodePool) GetDesiredBootstrapTokenHash 

func (hnp *HumioNodePool) GetDesiredBootstrapTokenHash() string

func (*HumioNodePool) GetDesiredPodHash 

func (hnp *HumioNodePool) GetDesiredPodHash() string

func (*HumioNodePool) GetDesiredPodRevision 

func (hnp *HumioNodePool) GetDesiredPodRevision() int

func (*HumioNodePool) GetDigestPartitionsCount 

func (hnp *HumioNodePool) GetDigestPartitionsCount() int

func (*HumioNodePool) GetEnvironmentVariables 

func (hnp *HumioNodePool) GetEnvironmentVariables() []corev1.EnvVar

func (*HumioNodePool) GetEnvironmentVariablesSource 

func (hnp *HumioNodePool) GetEnvironmentVariablesSource() []corev1.EnvFromSource

func (*HumioNodePool) GetExtraHumioVolumeMounts 

func (hnp *HumioNodePool) GetExtraHumioVolumeMounts() []corev1.VolumeMount

func (*HumioNodePool) GetExtraKafkaConfigs 

func (hnp *HumioNodePool) GetExtraKafkaConfigs() string

func (*HumioNodePool) GetExtraKafkaConfigsConfigMapName 

func (hnp *HumioNodePool) GetExtraKafkaConfigsConfigMapName() string

func (*HumioNodePool) GetExtraVolumes 

func (hnp *HumioNodePool) GetExtraVolumes() []corev1.Volume

func (*HumioNodePool) GetHelperImage 

func (hnp *HumioNodePool) GetHelperImage() string

func (*HumioNodePool) GetHostname 

func (hnp *HumioNodePool) GetHostname() string

func (*HumioNodePool) GetHumioESServicePort 

func (hnp *HumioNodePool) GetHumioESServicePort() int32

func (*HumioNodePool) GetHumioServiceAccountAnnotations 

func (hnp *HumioNodePool) GetHumioServiceAccountAnnotations() map[string]string

func (*HumioNodePool) GetHumioServiceAccountName 

func (hnp *HumioNodePool) GetHumioServiceAccountName() string

func (*HumioNodePool) GetHumioServiceAnnotations 

func (hnp *HumioNodePool) GetHumioServiceAnnotations() map[string]string

func (*HumioNodePool) GetHumioServiceLabels 

func (hnp *HumioNodePool) GetHumioServiceLabels() map[string]string

func (*HumioNodePool) GetHumioServicePort 

func (hnp *HumioNodePool) GetHumioServicePort() int32

func (*HumioNodePool) GetIDPCertificateSecretName 

func (hnp *HumioNodePool) GetIDPCertificateSecretName() string

func (*HumioNodePool) GetImage 

func (hnp *HumioNodePool) GetImage() string

func (*HumioNodePool) GetImagePullPolicy 

func (hnp *HumioNodePool) GetImagePullPolicy() corev1.PullPolicy

func (*HumioNodePool) GetImagePullSecrets 

func (hnp *HumioNodePool) GetImagePullSecrets() []corev1.LocalObjectReference

func (*HumioNodePool) GetImageSource 

func (hnp *HumioNodePool) GetImageSource() *humiov1alpha1.HumioImageSource

func (*HumioNodePool) GetIngress 

func (hnp *HumioNodePool) GetIngress() humiov1alpha1.HumioClusterIngressSpec

func (*HumioNodePool) GetInitClusterRoleBindingName 

func (hnp *HumioNodePool) GetInitClusterRoleBindingName() string

func (*HumioNodePool) GetInitClusterRoleName 

func (hnp *HumioNodePool) GetInitClusterRoleName() string

func (*HumioNodePool) GetInitServiceAccountName 

func (hnp *HumioNodePool) GetInitServiceAccountName() string

func (HumioNodePool) GetInitServiceAccountSecretName 

func (hnp HumioNodePool) GetInitServiceAccountSecretName() string

func (*HumioNodePool) GetLabelsForSecret 

func (hnp *HumioNodePool) GetLabelsForSecret(secretName string) map[string]string

func (*HumioNodePool) GetNamespace 

func (hnp *HumioNodePool) GetNamespace() string

func (*HumioNodePool) GetNodeCount 

func (hnp *HumioNodePool) GetNodeCount() int

func (*HumioNodePool) GetNodePoolFeatureAllowedAPIRequestTypes 

func (hnp *HumioNodePool) GetNodePoolFeatureAllowedAPIRequestTypes() []string

func (*HumioNodePool) GetNodePoolLabels 

func (hnp *HumioNodePool) GetNodePoolLabels() map[string]string

func (*HumioNodePool) GetNodePoolName 

func (hnp *HumioNodePool) GetNodePoolName() string

func (*HumioNodePool) GetPath 

func (hnp *HumioNodePool) GetPath() string

func (*HumioNodePool) GetPodAnnotations 

func (hnp *HumioNodePool) GetPodAnnotations() map[string]string

func (*HumioNodePool) GetPodDisruptionBudget 

func (hnp *HumioNodePool) GetPodDisruptionBudget() *humiov1alpha1.HumioPodDisruptionBudgetSpec

func (*HumioNodePool) GetPodDisruptionBudgetName 

func (hnp *HumioNodePool) GetPodDisruptionBudgetName() string

func (*HumioNodePool) GetPodLabels 

func (hnp *HumioNodePool) GetPodLabels() map[string]string

func (*HumioNodePool) GetPodSecurityContext 

func (hnp *HumioNodePool) GetPodSecurityContext() *corev1.PodSecurityContext

func (*HumioNodePool) GetPriorityClassName 

func (hnp *HumioNodePool) GetPriorityClassName() string

func (*HumioNodePool) GetProbeScheme 

func (hnp *HumioNodePool) GetProbeScheme() corev1.URIScheme

func (*HumioNodePool) GetResources 

func (hnp *HumioNodePool) GetResources() corev1.ResourceRequirements

func (*HumioNodePool) GetRolePermissions 

func (hnp *HumioNodePool) GetRolePermissions() string

func (*HumioNodePool) GetRolePermissionsConfigMapName 

func (hnp *HumioNodePool) GetRolePermissionsConfigMapName() string

func (*HumioNodePool) GetServiceName 

func (hnp *HumioNodePool) GetServiceName() string

func (*HumioNodePool) GetServiceType 

func (hnp *HumioNodePool) GetServiceType() corev1.ServiceType

func (*HumioNodePool) GetShareProcessNamespace 

func (hnp *HumioNodePool) GetShareProcessNamespace() *bool

func (*HumioNodePool) GetSidecarContainers 

func (hnp *HumioNodePool) GetSidecarContainers() []corev1.Container

func (*HumioNodePool) GetState 

func (hnp *HumioNodePool) GetState() string

func (*HumioNodePool) GetTLSSpec 

func (hnp *HumioNodePool) GetTLSSpec() *humiov1alpha1.HumioClusterTLSSpec

func (*HumioNodePool) GetTargetReplicationFactor 

func (hnp *HumioNodePool) GetTargetReplicationFactor() int

func (*HumioNodePool) GetTerminationGracePeriodSeconds 

func (hnp *HumioNodePool) GetTerminationGracePeriodSeconds() *int64

func (*HumioNodePool) GetTolerations 

func (hnp *HumioNodePool) GetTolerations() []corev1.Toleration

func (*HumioNodePool) GetTopologySpreadConstraints 

func (hnp *HumioNodePool) GetTopologySpreadConstraints() []corev1.TopologySpreadConstraint

func (*HumioNodePool) GetUpdateStrategy 

func (hnp *HumioNodePool) GetUpdateStrategy() *humiov1alpha1.HumioUpdateStrategy

func (*HumioNodePool) GetViewGroupPermissions 

func (hnp *HumioNodePool) GetViewGroupPermissions() string

func (*HumioNodePool) GetViewGroupPermissionsConfigMapName 

func (hnp *HumioNodePool) GetViewGroupPermissionsConfigMapName() string

func (*HumioNodePool) GetZoneUnderMaintenance 

func (hnp *HumioNodePool) GetZoneUnderMaintenance() string

func (*HumioNodePool) HumioServiceAccountIsSetByUser 

func (hnp *HumioNodePool) HumioServiceAccountIsSetByUser() bool

func (*HumioNodePool) InitContainerDisabled 

func (hnp *HumioNodePool) InitContainerDisabled() bool

func (*HumioNodePool) InitServiceAccountIsSetByUser 

func (hnp *HumioNodePool) InitServiceAccountIsSetByUser() bool

func (*HumioNodePool) IsDownscalingFeatureEnabled 

func (hnp *HumioNodePool) IsDownscalingFeatureEnabled() bool

IsDownscalingFeatureEnabled Checks if the LogScale version is >= v1.173.0 in order to use the reliable downscaling feature. If the LogScale version checks out, then it returns the value of the enableDownscalingFeature feature flag from the cluster configuration

func (*HumioNodePool) OkToDeletePvc 

func (hnp *HumioNodePool) OkToDeletePvc() bool

func (*HumioNodePool) PVCsEnabled 

func (hnp *HumioNodePool) PVCsEnabled() bool

func (*HumioNodePool) SetImage 

func (hnp *HumioNodePool) SetImage(image string)

func (*HumioNodePool) TLSEnabled 

func (hnp *HumioNodePool) TLSEnabled() bool

type HumioNodePoolList 

type HumioNodePoolList struct {
	Items []*HumioNodePool
}

func (*HumioNodePoolList) Add 

func (n *HumioNodePoolList) Add(hnp *HumioNodePool)

func (*HumioNodePoolList) Filter 

func (n *HumioNodePoolList) Filter(f func(*HumioNodePool) bool) []*HumioNodePool

type HumioParserReconciler 

type HumioParserReconciler struct {
	client.Client
	BaseLogger  logr.Logger
	Log         logr.Logger
	HumioClient humio.Client
	Namespace   string
}

HumioParserReconciler reconciles a HumioParser object

func (*HumioParserReconciler) Reconcile 

func (r *HumioParserReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HumioParserReconciler) SetupWithManager 

func (r *HumioParserReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type HumioRepositoryReconciler 

type HumioRepositoryReconciler struct {
	client.Client
	BaseLogger  logr.Logger
	Log         logr.Logger
	HumioClient humio.Client
	Namespace   string
}

HumioRepositoryReconciler reconciles a HumioRepository object

func (*HumioRepositoryReconciler) Reconcile 

func (r *HumioRepositoryReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HumioRepositoryReconciler) SetupWithManager 

func (r *HumioRepositoryReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type HumioScheduledSearchReconciler 

type HumioScheduledSearchReconciler struct {
	client.Client
	BaseLogger  logr.Logger
	Log         logr.Logger
	HumioClient humio.Client
	Namespace   string
}

HumioScheduledSearchReconciler reconciles a HumioScheduledSearch object

func (*HumioScheduledSearchReconciler) Reconcile 

func (r *HumioScheduledSearchReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HumioScheduledSearchReconciler) SetupWithManager 

func (r *HumioScheduledSearchReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type HumioVersion 

type HumioVersion struct {
	// contains filtered or unexported fields
}

func HumioVersionFromString 

func HumioVersionFromString(image string) *HumioVersion

func (*HumioVersion) AtLeast 

func (hv *HumioVersion) AtLeast(version string) (bool, error)

func (*HumioVersion) IsLatest 

func (hv *HumioVersion) IsLatest() bool

func (*HumioVersion) SemVer 

func (hv *HumioVersion) SemVer() *semver.Version

func (*HumioVersion) String 

func (hv *HumioVersion) String() string

type HumioViewReconciler 

type HumioViewReconciler struct {
	client.Client
	BaseLogger  logr.Logger
	Log         logr.Logger
	HumioClient humio.Client
	Namespace   string
}

HumioViewReconciler reconciles a HumioView object

func (*HumioViewReconciler) Reconcile 

func (r *HumioViewReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*HumioViewReconciler) SetupWithManager 

func (r *HumioViewReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type Option 

type Option interface {
	Apply(hc *humiov1alpha1.HumioCluster)
	GetResult() (reconcile.Result, error)
}

type StatusOptions 

type StatusOptions interface {
	Get() []Option
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.