Get retrieves the VLAgent from the indexer for a given namespace and name. Objects returned here must be treated as read-only.

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

PrefixedName returns name of resource with fixed prefix

Implement the flag.Value interface

GetTestClientWithObjects returns testing client with optional predefined objects

Info implements logr.Logger

Scheme implements interface.

WithContext returns logger from context or global

Validate validates raw config

MustGetBaseConfig returns operator configuration with default values populated from env variables

Merge labels create a new map with labels merged.

FinalLabels returns global labels for all vlagent related resources

List lists all VLAgents in the indexer. Objects returned here must be treated as read-only.

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

GetServiceAccountName returns ServiceAccount for resource

Error implements logr.Logger

WithName implements logr.Logger

WithValues implements logr.Logger

FinalAnnotations implements build.builderOpts interface

IsOwnsServiceAccount checks if serviceAccount belongs to the CR

Service - reconcile needed and actual state of service for given crd, it will recreate service if needed. NOTE it doesn't perform validation: in case

AddToContext adds given logger into context

RegisterObjectStat registers or deregisters object at metrics

BuildPathWithPrefixFlag returns provided path with possible prefix from flags

NameOrDefault returns name or default value with suffix

MergePatchContainers adds patches to base using a strategic merge patch and iterating by container name, failing on the first error

PodAnnotations returns pod metadata annotations

PodLabels returns labels for pod metadata

Reconcile general reconcile method for controller +kubebuilder:rbac:groups=operator.victoriametrics.com,resources=vlogs,verbs=get;list;watch;create;up

collectGarbage checks if resource must be freed from finalizer and prepares it for garbage collection by kubernetes

VMServiceScrape creates or updates given object

PDB creates or updates PodDisruptionBudget

SafeDeleteWithFinalizer removes object, ignores notfound error.

SanitizeVolumeName replaces all incompatible with k8s characters with -

GetTestClientWithActionsAndObjects returns a client that tracks actions and updates status/objects

IsSomeAndThen applies callback to the additionalServiceSpec if it's not nil or do not used as default service

SafeDelete removes object, ignores notfound error.

Deployment performs an update or create operator for deployment and waits until it's replicas is ready

HTTPProtoFromFlags returns HTTP protocol prefix from provided flags

skip validation, if object has annotation.

Owns returns error if owned by other CR

AddFinalizer adds finalizer to instance if needed.

GetTestClientWithActions returns a client that tracks actions

PrefixedInternalName returns prefixed name for the given component kind

ResyncAfterDuration returns requeue duration for object period reconcile adds 10% jitter

nolint:dupl,lll

Error implements errors.Error interface

RemoveOrphanedVMServiceScrapes removes VMSeviceScrapes detached from given object

ServiceAccount creates service account or updates exist one

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

HPA creates or update horizontalPodAutoscaler object

VPA creates or updates VerticalPodAutoscaler object

VisitSelected applies given function to any T child object matched by selectors defined in parent obj selectors

RemoveOrphanedServices removes Services detached from given object

Throttle registers reconcile event and checks if it must be throttled

UseTLS returns true if TLS is enabled

ExpectObjectStatus perform assert on given object status nolint:dupl,lll

Secret reconciles secret object

StatefulSet performs create and update operations for given statefulSet with STSOptions

UseProxyProtocol is a helper for build.probeCRD interface implementations

removeOrphaned removes orphaned resources

IntoSTSVolume converts storageSpec into proper volume for statefulsetSpec by default, it adds emptyDir volume.

AvailableStorageNodeIDs returns ids of the storage nodes for the provided component

GetStorageVolumeName returns formatted name for vtstorage volume

HasSpecChanges compares single spec with last applied single spec stored in annotation