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

WithContext returns logger from context or global

Validate validates raw config

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

Has reports whether id is currently tracked.

Add registers id and returns a child context for it.

WithValues implements logr.Logger

AddToContext adds given logger into context

RegisterObjectStat registers or deregisters object at metrics

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

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

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

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

NetworkPolicy creates or updates a NetworkPolicy

Reference returns the fully qualified container image reference. When Tag is a digest ("algorithm:hex") it is joined to Repository with "@"; otherwise

SafeDelete removes object, ignores notfound error.

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

SafeDeleteWithFinalizer removes object, ignores notfound error.

nolint:dupl,lll

PDB creates or updates PodDisruptionBudget

VPA creates or updates VerticalPodAutoscaler object

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

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

AddFinalizer adds finalizer to instance if needed.

Error implements errors.Error interface

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

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

GetTestClientWithActions returns a client that tracks actions

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

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

PrefixedInternalName returns prefixed name for the given component kind

ServiceAccount creates service account or updates exist one

IsUnmanaged checks if object should managed any config objects

PrefixedName returns prefixed name for the given component kind

RemoveOrphanedVMServiceScrapes removes VMServiceScrapes detached from given object

Stop marks id as finished and triggers self-cancel when all goroutines are done.

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.

Set implements the flag.Set interface.