RemoveOrphanedServices removes Services detached from given object

Secret reconciles secret object.

StatusForChildObjects reconciles status sub-resources for the full, current set of child objects selected by a parent. Expects parentObjectName in the

UseTLS returns true if TLS is enabled

removeOrphaned removes orphaned resources

waitForStatus waits till obj reaches defined status

CreateOrUpdate creates deployment for vmagent and configures it waits for healthy state

StatefulSet performs create and update operations for given statefulSet with STSOptions

UseProxyProtocol is a helper for build.probeCRD interface implementations

CreateOrUpdate reconciled cluster object with order first we check status of vmStorage and waiting for its readiness then vmSelect and wait for it rea

GetTestClientWithObjectsAndInterceptors returns testing client with optional predefined objects and interceptors

HasConfigReloader reports whether vmauth's pod spec includes a config-reloader sidecar - only true when the operator itself owns and writes the auth c

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

ListObjectsByNamespace performs object list for given namespaces

MergeSpecs substitutes ZonePlaceholder in a with name, then deep-merges b on top.

AvailableStorageNodeIDs returns ids of the storage nodes for the provided component

FetchMetricsValues issues a single HTTP GET to url and extracts every sample matching any of the given queries, returning metric name -> (dimension va

GetStorageVolumeName returns formatted name for vtstorage volume

Load returns vmanomaly config merged with provided secrets

isSelectorsMatchesTargetCRD checks if targetCRD matches sourceCRD by entity selectors and selectAll. see https://docs.victoriametrics.com/operator/res

BuildLocalURL builds API path for given args

ConfigMap reconciles configmap object

ConvertVMAuthUsers converts a victoria-metrics-auth chart's config.users entries into standalone VMUser CRs. Returned separately from Convert since ea

CreateOrUpdate creates vmalert deployment for given CRD

CreateOrUpdate creates vmanomaly and builds config for it

CreateOrUpdate handles VL deployment reconciliation.

CreateOrUpdate performs an update for single node resource

FilterPrefixes filters given prefixes from src map

IsClusterWideAccessAllowed checks if cluster wide access for components is needed

IsProvided returns true if license is provided.

IsSharded returns true if sharding is enabled

MaybeAddArgoCDIgnoreAnnotations optionally adds ArgoCD annotations

NewReadyDeployment returns a new deployment with ready status condition

NewReconcileRateLimiter returns limiter with limit per 2 seconds

PodIsReady check is pod is ready

PrefixedName format name of the component with hard-coded prefix

PrefixedName returns name of resource with fixed prefix

PrefixedName returns prefixed name for the given component kind

PrefixedName returns prefixed name for the given component kind

RemoveFinalizer removes finalizer from instance if needed.

ResolveServiceURL returns the service name and port for building a CR's URL. When isExtra is true it targets the additional service (spec.serviceSpec)

StatusForChildObject is a fast path for updating a single child object that triggered the reconcile, bypassing the release-on-drop tracking used by St

String implements Stringer interface

Validate checks if spec is correct

WatchUntilStatusReached starts a watch on the named object and waits until it reaches targetStatus. Uses minGen=0 (matches any generation), suitable w

nolint:dupl,lll

nolint:dupl,lll,unparam

AsOwner returns owner references with current object as owner

ConvertRelabelConfig converts Prometheus relabel config to VM one

CreateOrUpdate syncs VTCluster object to the desired state

CreateOrUpdate handles VM deployment reconciliation.

CreateOrUpdate - handles VMAuth deployment reconciliation.

CreateOrUpdateRuleConfigMaps conditionally selects vmrules and stores content at configmaps. Alerting rules are dropped when hasNotifiers is false, si

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

GetMetricsAddrs discovers the agent's active endpoints from EndpointSlices and returns the full metrics URL for each ready endpoint.

HasAnyRule returns true if there is at least one aggregation rule

HasRemoteWriteSecrets reports whether any remoteWrite entry references a credential secret.

HasUnknownFields reports whether a ParsingSpecError was caused by unknown spec fields. Webhook ValidateUpdate uses this to allow updates to CRs that c

OnClusterLoadBalancerDelete removes vmauth loadbalancer components for cluster

OnInsertDelete removes all objects related to insert component

OnSelectDelete removes all objects related to select component

OnStorageDelete removes all objects related to storage component

Port returns port for accessing anomaly UI

PrefixedName format name of the component with hard-coded prefix