MCPcopy Create free account

hub / github.com/VictoriaMetrics/operator / functions

Functions3,591 in github.com/VictoriaMetrics/operator

↓ 9 callersFunctionUseProxyProtocol
UseProxyProtocol is a helper for build.probeCRD interface implementations
api/operator/v1beta1/vmextra_types.go:190
↓ 9 callersFunctiongenerateRelabelConfig
(rc *vmv1beta1.RelabelConfig)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:172
↓ 9 callersFunctionremoveOrphaned
removeOrphaned removes orphaned resources
internal/controller/operator/factory/finalize/orphaned.go:119
↓ 8 callersFunctionCreateOrUpdate
CreateOrUpdate reconciled cluster object with order first we check status of vmStorage and waiting for its readiness then vmSelect and wait for it rea
internal/controller/operator/factory/vmcluster/vmcluster.go:37
↓ 8 callersMethodIntoSTSVolume
IntoSTSVolume converts storageSpec into proper volume for statefulsetSpec by default, it adds emptyDir volume.
api/operator/v1beta1/vmextra_types.go:239
↓ 8 callersMethodIsUnmanaged
IsUnmanaged checks if object should managed any config objects
api/operator/v1beta1/vmauth_types.go:764
↓ 8 callersFunctionListObjectsByNamespace
ListObjectsByNamespace performs object list for given namespaces
internal/controller/operator/factory/k8stools/client_utils.go:109
↓ 8 callersMethodPrefixedName
()
api/operator/v1beta1/vmalertmanager_types.go:373
↓ 8 callersMethodPrefixedName
()
api/operator/v1beta1/vmsingle_types.go:332
↓ 8 callersFunctionhandleReconcileErr
(ctx context.Context, rclient client.Client, object client.Object, originResult ctrl.Result, err error)
internal/controller/operator/controllers.go:143
↓ 7 callersMethodAsOwner
()
internal/controller/operator/factory/finalize/common.go:18
↓ 7 callersMethodAvailableStorageNodeIDs
AvailableStorageNodeIDs returns ids of the storage nodes for the provided component
api/operator/v1/vtcluster_types.go:716
↓ 7 callersFunctionCreateOrUpdate
CreateOrUpdate creates deployment for vmagent and configures it waits for healthy state
internal/controller/operator/factory/vmagent/vmagent.go:121
↓ 7 callersMethodGetStorageVolumeName
GetStorageVolumeName returns formatted name for vtstorage volume
api/operator/v1/vtcluster_types.go:509
↓ 7 callersMethodLoad
Load returns vmanomaly config merged with provided secrets
internal/controller/operator/factory/vmanomaly/config/config.go:59
↓ 7 callersFunctiondiffDeep
(desired, current any, root string)
internal/controller/operator/factory/reconcile/diff.go:117
↓ 7 callersFunctionexpectPodCount
(ctx context.Context, rclient client.Client, obj client.Object, count int)
test/e2e/utils_test.go:99
↓ 7 callersFunctionisSelectorsMatchesTargetCRD
isSelectorsMatchesTargetCRD checks if targetCRD matches sourceCRD by entity selectors and selectAll. see https://docs.victoriametrics.com/operator/res
internal/controller/operator/controllers.go:239
↓ 7 callersFunctionwaitForStatus
waitForStatus waits till obj reaches defined status
internal/controller/operator/factory/reconcile/reconcile.go:193
↓ 6 callersFunctionBuildLocalURL
BuildLocalURL builds API path for given args
api/operator/v1beta1/vmextra_types.go:417
↓ 6 callersFunctionConfigMap
ConfigMap reconciles configmap object
internal/controller/operator/factory/reconcile/configmap.go:18
↓ 6 callersFunctionCreateOrUpdate
CreateOrUpdate performs an update for single node resource
internal/controller/operator/factory/vmsingle/vmsingle.go:78
↓ 6 callersFunctionFilterPrefixes
FilterPrefixes filters given prefixes from src map
internal/controller/operator/factory/converter/apis.go:529
↓ 6 callersFunctionGetTestClientWithObjectsAndInterceptors
GetTestClientWithObjectsAndInterceptors returns testing client with optional predefined objects and interceptors
internal/controller/operator/factory/k8stools/test_helpers.go:98
↓ 6 callersFunctionIsClusterWideAccessAllowed
IsClusterWideAccessAllowed checks if cluster wide access for components is needed
internal/config/config.go:955
↓ 6 callersMethodIsProvided
IsProvided returns true if license is provided.
api/operator/v1beta1/vmextra_types.go:1056
↓ 6 callersFunctionMaybeAddArgoCDIgnoreAnnotations
MaybeAddArgoCDIgnoreAnnotations optionally adds ArgoCD annotations
internal/controller/operator/factory/converter/apis.go:89
↓ 6 callersFunctionNewReadyDeployment
NewReadyDeployment returns a new deployment with ready status condition
internal/controller/operator/factory/k8stools/test_helpers.go:194
↓ 6 callersFunctionNewReconcileRateLimiter
NewReconcileRateLimiter returns limiter with limit per 2 seconds
internal/controller/operator/factory/limiter/limiter.go:41
↓ 6 callersMethodOperatorV1
()
api/client/versioned/clientset.go:36
↓ 6 callersMethodPrefixedName
()
api/operator/v1beta1/vmauth_types.go:720
↓ 6 callersMethodPrefixedName
()
api/operator/v1beta1/vmalert_types.go:456
↓ 6 callersMethodPrefixedName
PrefixedName format name of the component with hard-coded prefix
api/operator/v1/vtsingle_types.go:274
↓ 6 callersMethodPrefixedName
PrefixedName returns prefixed name for the given component kind
api/operator/v1/vtcluster_types.go:179
↓ 6 callersMethodPrefixedName
PrefixedName returns prefixed name for the given component kind
api/operator/v1/vlcluster_types.go:184
↓ 6 callersMethodRESTClient
()
api/client/versioned/typed/operator/v1/operator_client.go:29
↓ 6 callersFunctionRemoveFinalizer
RemoveFinalizer removes finalizer from instance if needed.
internal/controller/operator/factory/finalize/common.go:58
↓ 6 callersFunctionResolveServiceURL
ResolveServiceURL returns the service name and port for building a CR's URL. When isExtra is true it targets the additional service (spec.serviceSpec)
api/operator/v1beta1/vmextra_types.go:399
↓ 6 callersMethodString
String implements Stringer interface
api/operator/v1beta1/vmextra_types.go:1800
↓ 6 callersMethodValidate
Validate checks if spec is correct
api/operator/v1beta1/vlogs_types.go:267
↓ 6 callersFunctionaddCommonScrapeParamsTo
(cfg yaml.MapSlice, cs vmv1beta1.EndpointScrapeParams, se *vmv1beta1.CommonScrapeSecurityEnforcements)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:477
↓ 6 callersFunctionaddEndpointAuthTo
(cfg yaml.MapSlice, ea *vmv1beta1.EndpointAuth, namespace string, ac *build.AssetsCache)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:552
↓ 6 callersFunctionaddMetricRelabelingsTo
(cfg yaml.MapSlice, src []*vmv1beta1.RelabelConfig, se *vmv1beta1.CommonScrapeSecurityEnforcements)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:532
↓ 6 callersFunctionassertAnnotationsOnObjects
nolint:dupl,lll
test/e2e/utils_test.go:193
↓ 6 callersFunctionbuildVMScrapeParams
(namespace string, cfg *vmv1beta1.VMScrapeParams, ac *build.AssetsCache)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:396
↓ 6 callersFunctioncollectVMAgentScrapes
(l logr.Logger, ctx context.Context, rclient client.Client, watchNamespaces []string, instance client.Object)
internal/controller/operator/vmagent_controller.go:158
↓ 6 callersFunctioncollectVMSingleScrapes
(l logr.Logger, ctx context.Context, rclient client.Client, watchNamespaces []string, instance client.Object)
internal/controller/operator/vmsingle_controller.go:149
↓ 6 callersFunctionconvertSliceStruct
(src []T, convert func(T) D)
internal/controller/operator/factory/converter/v1alpha1/apis.go:206
↓ 6 callersFunctionenforceNamespaceLabel
(relabelings []yaml.MapSlice, namespace, enforcedNamespaceLabel string)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:386
↓ 6 callersFunctiongetAssetsCache
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAgent)
internal/controller/operator/factory/vmagent/vmagent.go:1326
↓ 6 callersFunctiongetAssetsCache
(ctx context.Context, rclient client.Client)
internal/controller/operator/factory/vmscrapes/vmscrapes_test.go:91
↓ 6 callersFunctiongetScrapeClass
(name *string, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:742
↓ 6 callersFunctionhasVolumeMount
nolint:dupl,lll,unparam
test/e2e/utils_test.go:246
↓ 6 callersFunctionmergeEndpointAuthWithScrapeClass
(authz *vmv1beta1.EndpointAuth, scrapeClass *vmv1beta1.ScrapeClass)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:599
↓ 6 callersFunctionmergeMetaWithConversion
(existingObj, newObj client.Object, prevMeta *metav1.ObjectMeta, owner *metav1.OwnerReference, shouldRemoveFin
internal/controller/operator/factory/reconcile/reconcile.go:102
↓ 6 callersFunctionsetScrapeIntervalToWithLimit
(ctx context.Context, dst *vmv1beta1.EndpointScrapeParams, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:25
↓ 6 callersMethodstart
(ctx context.Context)
cmd/config-reloader/main.go:272
↓ 5 callersMethodAsOwner
AsOwner returns owner references with current object as owner
api/operator/v1beta1/vmcluster_types.go:302
↓ 5 callersFunctionConvertRelabelConfig
ConvertRelabelConfig converts Prometheus relabel config to VM one
internal/controller/operator/factory/converter/apis.go:305
↓ 5 callersFunctionCreateLicenseSecret
(ctx context.Context, k8sClient client.Client, namespace string)
test/e2e/common.go:16
↓ 5 callersFunctionCreateOrUpdate
CreateOrUpdate syncs VTCluster object to the desired state
internal/controller/operator/factory/vtcluster/cluster.go:21
↓ 5 callersFunctionCreateOrUpdate
CreateOrUpdate creates vmalert deployment for given CRD
internal/controller/operator/factory/vmalert/vmalert.go:100
↓ 5 callersFunctionCreateOrUpdate
CreateOrUpdate handles VM deployment reconciliation.
internal/controller/operator/factory/vmdistributed/vmdistributed.go:25
↓ 5 callersMethodDeepCopyObject
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
api/operator/v1/zz_generated.deepcopy.go:215
↓ 5 callersFunctionGetClient
(data []byte)
test/e2e/suite/suite.go:53
↓ 5 callersMethodHasAnyRelabellingConfigs
HasAnyRelabellingConfigs checks if vmagent has any defined relabeling rules
api/operator/v1beta1/vmagent_types.go:681
↓ 5 callersMethodHasAnyRule
HasAnyRule returns true if there is at least one aggregation rule
api/operator/v1beta1/vmextra_types.go:711
↓ 5 callersMethodHasAnyStreamAggrRule
HasAnyStreamAggrRule checks if vmagent has any defined aggregation rules
api/operator/v1beta1/vmagent_types.go:695
↓ 5 callersFunctionOnClusterLoadBalancerDelete
OnClusterLoadBalancerDelete removes vmauth loadbalancer components for cluster
internal/controller/operator/factory/finalize/cluster.go:139
↓ 5 callersFunctionOnInsertDelete
OnInsertDelete removes all objects related to insert component
internal/controller/operator/factory/finalize/cluster.go:54
↓ 5 callersFunctionOnSelectDelete
OnSelectDelete removes all objects related to select component
internal/controller/operator/factory/finalize/cluster.go:82
↓ 5 callersFunctionOnStorageDelete
OnStorageDelete removes all objects related to storage component
internal/controller/operator/factory/finalize/cluster.go:111
↓ 5 callersMethodPatch
(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...
api/client/versioned/typed/operator/v1/vlagent.go:48
↓ 5 callersFunctionPodIsReady
PodIsReady check is pod is ready
internal/controller/operator/factory/reconcile/statefulset.go:397
↓ 5 callersMethodPort
Port returns port for accessing anomaly UI
api/operator/v1/vmanomaly_types.go:435
↓ 5 callersMethodPrefixedName
PrefixedName format name of the component with hard-coded prefix
api/operator/v1/vmanomaly_types.go:389
↓ 5 callersMethodPrefixedName
PrefixedName returns name of resource with fixed prefix
api/operator/v1/vlagent_types.go:425
↓ 5 callersFunctionRemoveOrphanedPDBs
RemoveOrphanedPDBs removes PDBs detached from given object
internal/controller/operator/factory/finalize/orphaned.go:48
↓ 5 callersMethodResourceLabels
ResourceLabels returns combination of selector, resource and managed labels
api/operator/v1/vlsingle_types.go:270
↓ 5 callersFunctionRole
Role reconciles role object
internal/controller/operator/factory/reconcile/rbac.go:57
↓ 5 callersFunctionRoleBinding
RoleBinding reconciles rolebindg object
internal/controller/operator/factory/reconcile/rbac.go:18
↓ 5 callersFunctionStatusForChildObjects
StatusForChildObjects reconciles status sub-resources Expects parentObjectName in the following form: NAME.NAMESPACE.RESOURCE for example vmalertmana
internal/controller/operator/factory/reconcile/status.go:40
↓ 5 callersMethodVMAgentName
VMAgentName returns the name of the VMAgent for zone.
api/operator/v1alpha1/vmdistributed_types.go:140
↓ 5 callersMethodVMClusterName
VMClusterName return cluster name for zone
api/operator/v1alpha1/vmdistributed_types.go:152
↓ 5 callersFunctionVMPodScrape
VMPodScrape creates or updates given object
internal/controller/operator/factory/reconcile/vmpodscrape.go:19
↓ 5 callersFunctionWatchUntilStatusReached
WatchUntilStatusReached starts a watch on the named object and waits until it reaches targetStatus. Uses minGen=0 (matches any generation), suitable w
test/e2e/suite/utils.go:130
↓ 5 callersMethodclose
()
cmd/config-reloader/main.go:298
↓ 5 callersMethodclose
()
cmd/config-reloader/main.go:324
↓ 5 callersFunctiongetAssetsCache
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAlertmanager)
internal/controller/operator/factory/vmalertmanager/statefulset.go:448
↓ 5 callersFunctionhasVolume
nolint:dupl,lll,unparam
test/e2e/utils_test.go:233
↓ 5 callersFunctionmergeEndpointRelabelingsWithScrapeClass
(ers *vmv1beta1.EndpointRelabelings, scrapeClass *vmv1beta1.ScrapeClass)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:620
↓ 5 callersFunctionnewDirWatchers
newDirWatchers watches dirs; targetDirs is paired by index with dirs (dirs[i] → targetDirs[i]). If targetDirs is non-empty it must have the same lengt
cmd/config-reloader/file_watch.go:185
↓ 5 callersMethodstart
(ctx context.Context, updates chan struct{})
cmd/config-reloader/main.go:323
↓ 4 callersFunctionClusterRole
ClusterRole reconciles cluster role object
internal/controller/operator/factory/reconcile/rbac.go:132
↓ 4 callersFunctionClusterRoleBinding
ClusterRoleBinding reconciles cluster role binding object
internal/controller/operator/factory/reconcile/rbac.go:93
↓ 4 callersFunctionConvertAuthorization
ConvertAuthorization converts prometheus auth struct to VM one
internal/controller/operator/factory/converter/apis.go:179
↓ 4 callersFunctionConvertBasicAuth
ConvertBasicAuth converts Prometheus basic auth config to VM one
internal/controller/operator/factory/converter/apis.go:244
↓ 4 callersFunctionConvertOAuth
ConvertOAuth converts prometheus OAuth config to VM one
internal/controller/operator/factory/converter/apis.go:163
↓ 4 callersFunctionConvertSafeTLSConfig
ConvertSafeTLSConfig performs convert ConvertSafeTLSConfig to vm version
internal/controller/operator/factory/converter/apis.go:278
↓ 4 callersFunctionCreateOrUpdate
CreateOrUpdate performs an update for vtsingle resource
internal/controller/operator/factory/vtsingle/vtsingle.go:69
← previousnext →101–200 of 3,591, ranked by callers