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.

MustGetBaseConfig returns operator configuration with default values populated from env variables

Implement the flag.Value interface

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

newGetError wraps a client.Get failure as a reconcileError tagged reasonGetObject.

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

newParsingError wraps a stored ParsingSpecError message as a reconcileError tagged reasonParseObject.

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

NameOrDefault returns name or default value with suffix

BuildPathWithPrefixFlag returns provided path with possible prefix from flags

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

NetworkPolicy creates or updates a NetworkPolicy

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

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

SafeDeleteWithFinalizer removes object, ignores notfound error.

VMServiceScrape creates or updates given object

nolint:dupl,lll

+kubebuilder:rbac:groups=policy,resources=poddisruptionbudgets;poddisruptionbudgets/finalizers,verbs=* PDB creates or updates PodDisruptionBudget

SanitizeVolumeName replaces all incompatible with k8s characters with -

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

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

Owns returns error if owned by other CR

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

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

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

GetTestClientWithActions returns a client that tracks actions

+kubebuilder:rbac:groups=autoscaling,resources=horizontalpodautoscalers,verbs=* HPA creates or update horizontalPodAutoscaler object

HTTPProtoFromFlags returns HTTP protocol prefix from provided flags

skip validation, if object has annotation.

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

ServiceAccount creates service account or updates exist one

PrefixedInternalName returns prefixed name for the given component kind

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

Set implements the flag.Set interface.

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