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.

GetTestClientWithObjects returns testing client with optional predefined objects

Scheme implements interface.

Implement the flag.Value interface

MustGetBaseConfig returns operator configuration with default values populated from env variables

Info implements logr.Logger

Validate validates raw config

WithContext returns logger from context or global

Error implements logr.Logger

Merge labels create a new map with labels merged.

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.

FinalAnnotations implements build.builderOpts interface

GetServiceAccountName returns ServiceAccount for resource

WithName implements logr.Logger

WithValues implements logr.Logger

AddToContext adds given logger into context

RegisterObjectStat registers or deregisters object at metrics

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

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

BuildPathWithPrefixFlag returns provided path with possible prefix from flags

NameOrDefault returns name or default value with suffix

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

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

VMServiceScrape creates or updates given object

VPA creates or updates VerticalPodAutoscaler object

SafeDeleteWithFinalizer removes object, ignores notfound error.

PDB creates or updates PodDisruptionBudget

SafeDelete 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

nolint:dupl,lll

UnmarshalSpecStrict decodes spec JSON into v and rejects unknown fields. A lenient pass runs first so real parse errors (type mismatches, syntax) are

expectStatusAfterAction starts a watch on the named object, runs action, then waits for each status in sequence. The watch is started before the actio

AddFinalizer adds finalizer to instance if needed.

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

HPA creates or update horizontalPodAutoscaler object

HTTPProtoFromFlags returns HTTP protocol prefix from provided flags

skip validation, if object has annotation.

Owns returns error if owned by other CR

GetTestClientWithActions returns a client that tracks actions

Convert converts helm values to corresponding CRD

Error implements errors.Error interface

PrefixedInternalName returns prefixed name for the given component kind

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

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.

RemoveOrphanedVMServiceScrapes removes VMServiceScrapes detached from given object

Throttle registers reconcile event and checks if it must be throttled

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

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMCluster.

PrefixedName returns prefixed name for the given component kind

IsSharded returns true if sharding is enabled

RemoveOrphanedServices removes Services detached from given object

Secret reconciles secret object

UseTLS returns true if TLS is enabled

Set implements the flag.Set interface.

StatefulSet performs create and update operations for given statefulSet with STSOptions