MCPcopy Create free account

hub / github.com/VictoriaMetrics/operator / functions

Functions3,239 in github.com/VictoriaMetrics/operator

↓ 7 callersFunctionLastAppliedChangesAsPatch
LastAppliedChangesAsPatch builds patch request from provided spec
api/operator/v1beta1/vmextra_types.go:1083
↓ 7 callersFunctionListObjectsByNamespace
ListObjectsByNamespace performs object list for given namespaces
internal/controller/operator/factory/k8stools/client_utils.go:113
↓ 7 callersFunctionParseLastAppliedStateTo
ParseLastAppliedStateTo parses spec from provided CR annotations and sets it to the given CR
api/operator/v1beta1/vmextra_types.go:1051
↓ 7 callersMethodPrefixedName
()
api/operator/v1beta1/vmagent_types.go:540
↓ 7 callersMethodRun
Run - starts vmprometheusconverter with background discovery process for each prometheus api object
internal/controller/operator/vmprometheusconverter_controller.go:282
↓ 7 callersMethodSet
Set implements the flag.Set interface.
internal/config/config.go:796
↓ 7 callersFunctionexpectPodCount
(ctx context.Context, rclient client.Client, obj client.Object, count int)
test/e2e/utils_test.go:26
↓ 7 callersFunctionmergeLabelsWithStrategy
default merge strategy - prefer-prometheus old - from vm new - from prometheus by default new has priority
internal/controller/operator/vmprometheusconverter_controller.go:571
↓ 6 callersFunctionFilterPrefixes
FilterPrefixes filters given prefixes from src map
internal/controller/operator/converter/apis.go:531
↓ 6 callersMethodGetNamespace
()
test/e2e/utils_test.go:147
↓ 6 callersMethodIsSharded
IsSharded returns true if sharding is enabled
api/operator/v1/vmanomaly_types.go:472
↓ 6 callersMethodIsUnmanaged
IsUnmanaged checks if object should managed any config objects
api/operator/v1beta1/vmauth_types.go:705
↓ 6 callersFunctionMaybeAddArgoCDIgnoreAnnotations
MaybeAddArgoCDIgnoreAnnotations optionally adds ArgoCD annotations
internal/controller/operator/converter/apis.go:90
↓ 6 callersMethodOperatorV1
()
api/client/versioned/clientset.go:36
↓ 6 callersMethodPatch
(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...
api/client/versioned/typed/operator/v1/vlagent.go:48
↓ 6 callersMethodRESTClient
()
api/client/versioned/typed/operator/v1/operator_client.go:29
↓ 6 callersMethodStop
Stop performs a stop on all watchers and waits for it's finish
internal/controller/operator/factory/k8stools/client_utils.go:248
↓ 6 callersFunctionaddCommonScrapeParamsTo
(cfg yaml.MapSlice, cs vmv1beta1.EndpointScrapeParams, se *vmv1beta1.CommonScrapeSecurityEnforcements)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:601
↓ 6 callersFunctionaddEndpointAuthTo
(cfg yaml.MapSlice, ea *vmv1beta1.EndpointAuth, namespace string, ac *build.AssetsCache)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:676
↓ 6 callersFunctionaddMetricRelabelingsTo
(cfg yaml.MapSlice, src []*vmv1beta1.RelabelConfig, se *vmv1beta1.CommonScrapeSecurityEnforcements)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:656
↓ 6 callersFunctionassertAnnotationsOnObjects
nolint:dupl,lll
test/e2e/utils_test.go:233
↓ 6 callersFunctionbuildVMScrapeParams
(namespace string, cfg *vmv1beta1.VMScrapeParams, ac *build.AssetsCache)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:520
↓ 6 callersFunctioncollectVMAgentScrapes
(l logr.Logger, ctx context.Context, rclient client.Client, watchNamespaces []string, instance client.Object)
internal/controller/operator/vmagent_controller.go:156
↓ 6 callersFunctionconvertSliceStruct
(src []T, convert func(T) D)
internal/controller/operator/converter/v1alpha1/apis.go:210
↓ 6 callersFunctiondiffDeep
(desired, current any, root string)
internal/controller/operator/factory/reconcile/diff.go:117
↓ 6 callersFunctionenforceNamespaceLabel
(relabelings []yaml.MapSlice, namespace, enforcedNamespaceLabel string)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:510
↓ 6 callersFunctiongetMetaMergeStrategy
helper function - extracts meta merge strategy in the future we can introduce another merge strategies
internal/controller/operator/vmprometheusconverter_controller.go:590
↓ 6 callersFunctiongetScrapeClass
(name *string, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:880
↓ 6 callersFunctionhasVolumeMount
nolint:dupl,lll,unparam
test/e2e/utils_test.go:286
↓ 6 callersFunctionisMetaEqual
(left, right metav1.Object)
internal/controller/operator/vmprometheusconverter_controller.go:732
↓ 6 callersFunctionmergeEndpointAuthWithScrapeClass
(authz *vmv1beta1.EndpointAuth, scrapeClass *vmv1beta1.ScrapeClass)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:737
↓ 6 callersFunctionsetScrapeIntervalToWithLimit
(ctx context.Context, dst *vmv1beta1.EndpointScrapeParams, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:150
↓ 6 callersMethodstart
(ctx context.Context)
cmd/config-reloader/main.go:247
↓ 5 callersMethodAsURL
()
internal/controller/operator/factory/vmauth/vmusers_config.go:89
↓ 5 callersFunctionBuildLocalURL
BuildLocalURL builds API path for given args
api/operator/v1beta1/vmextra_types.go:349
↓ 5 callersFunctionConfigMap
ConfigMap reconciles configmap object
internal/controller/operator/factory/reconcile/configmap.go:18
↓ 5 callersFunctionConvertRelabelConfig
ConvertRelabelConfig converts Prometheus relabel config to VM one
internal/controller/operator/converter/apis.go:306
↓ 5 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
↓ 5 callersFunctionGetClient
(data []byte)
test/e2e/suite/suite.go:46
↓ 5 callersFunctionGetTestClientWithObjectsAndInterceptors
GetTestClientWithObjectsAndInterceptors returns testing client with optional predefined objects and interceptors
internal/controller/operator/factory/k8stools/test_helpers.go:95
↓ 5 callersFunctionIsClusterWideAccessAllowed
IsClusterWideAccessAllowed checks if cluster wide access for components is needed
internal/config/config.go:770
↓ 5 callersFunctionNewReadyDeployment
NewReadyDeployment returns a new deployment with ready status condition
internal/controller/operator/factory/k8stools/test_helpers.go:190
↓ 5 callersFunctionPodIsReady
PodIsReady check is pod is ready
internal/controller/operator/factory/reconcile/statefulset.go:381
↓ 5 callersMethodPrefixedName
()
api/operator/v1beta1/vmalertmanager_types.go:361
↓ 5 callersFunctionRemoveFinalizer
RemoveFinalizer removes finalizer from instance if needed.
internal/controller/operator/factory/finalize/common.go:58
↓ 5 callersFunctionRemoveOrphanedPDBs
RemoveOrphanedPDBs removes PDBs detached from given object
internal/controller/operator/factory/finalize/orphaned.go:48
↓ 5 callersMethodString
String implements Stringer interface
api/operator/v1beta1/vmextra_types.go:1523
↓ 5 callersMethodValidate
Validate checks if spec is correct
api/operator/v1beta1/vlogs_types.go:261
↓ 5 callersMethodclose
()
cmd/config-reloader/main.go:273
↓ 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:273
↓ 5 callersFunctionisSelectorsMatchesTargetCRD
isSelectorsMatchesTargetCRD checks if targetCRD matches sourceCRD by entity selectors and selectAll. see https://docs.victoriametrics.com/operator/res
internal/controller/operator/controllers.go:236
↓ 5 callersFunctionmergeEndpointRelabelingsWithScrapeClass
(ers *vmv1beta1.EndpointRelabelings, scrapeClass *vmv1beta1.ScrapeClass)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:758
↓ 5 callersFunctionmergeMaps
mergeMaps performs 3-way merge for labels and annotations it deletes only labels and annotations managed by operator CRDs 3-rd party kubernetes annota
internal/controller/operator/factory/reconcile/reconcile.go:55
↓ 4 callersFunctionConvertAuthorization
ConvertAuthorization converts prometheus auth struct to VM one
internal/controller/operator/converter/apis.go:180
↓ 4 callersFunctionConvertBasicAuth
ConvertBasicAuth converts Prometheus basic auth config to VM one
internal/controller/operator/converter/apis.go:245
↓ 4 callersFunctionConvertOAuth
ConvertOAuth converts prometheus OAuth config to VM one
internal/controller/operator/converter/apis.go:164
↓ 4 callersFunctionConvertSafeTLSConfig
ConvertSafeTLSConfig performs convert ConvertSafeTLSConfig to vm version
internal/controller/operator/converter/apis.go:279
↓ 4 callersFunctionCreateOrUpdate
CreateOrUpdate creates vmalert deployment for given CRD
internal/controller/operator/factory/vmalert/vmalert.go:96
↓ 4 callersFunctionCreateOrUpdate
CreateOrUpdate handles VM deployment reconciliation.
internal/controller/operator/factory/vmdistributed/vmdistributed.go:25
↓ 4 callersFunctionCreateOrUpdate
CreateOrUpdate creates deployment for vmagent and configures it waits for healthy state
internal/controller/operator/factory/vmagent/vmagent.go:120
↓ 4 callersFunctionCreateOrUpdate
CreateOrUpdate creates vmanomaly and builds config for it
internal/controller/operator/factory/vmanomaly/statefulset.go:35
↓ 4 callersFunctionCreateOrUpdate
CreateOrUpdate performs an update for single node resource
internal/controller/operator/factory/vmsingle/vmsingle.go:67
↓ 4 callersFunctionCreateOrUpdateConfig
CreateOrUpdateConfig - check if secret with config exist, if not create with predefined or user value.
internal/controller/operator/factory/vmalertmanager/statefulset.go:460
↓ 4 callersFunctionCreateOrUpdateRuleConfigMaps
CreateOrUpdateRuleConfigMaps conditionally selects vmrules and stores content at configmaps
internal/controller/operator/factory/vmalert/rules.go:24
↓ 4 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMCluster.
api/operator/v1beta1/zz_generated.deepcopy.go:5524
↓ 4 callersMethodDeepCopyObject
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
api/operator/v1/zz_generated.deepcopy.go:219
↓ 4 callersFunctionFromGinkgoReport
(report types.Report)
test/e2e/suite/allure/api.go:19
↓ 4 callersMethodGetShardCount
GetShardCount returns shard count for vmanomaly
api/operator/v1/vmanomaly_types.go:477
↓ 4 callersMethodGetStatusMetadata
()
internal/controller/operator/factory/reconcile/status.go:31
↓ 4 callersMethodGetVolumeName
GetVolumeName returns volume name for persistent storage
api/operator/v1/vmanomaly_types.go:422
↓ 4 callersMethodInit
(client.Client, logr.Logger, *runtime.Scheme, *config.BaseOperatorConf)
internal/manager/manager.go:475
↓ 4 callersFunctionNewReconcileRateLimiter
NewReconcileRateLimiter returns limiter with limit per 2 seconds
internal/controller/operator/factory/limiter/limiter.go:41
↓ 4 callersFunctionOnClusterLoadBalancerDelete
OnClusterLoadBalancerDelete removes vmauth loadbalancer components for cluster
internal/controller/operator/factory/finalize/cluster.go:139
↓ 4 callersFunctionOnInsertDelete
OnInsertDelete removes all objects related to insert component
internal/controller/operator/factory/finalize/cluster.go:54
↓ 4 callersFunctionOnSelectDelete
OnSelectDelete removes all objects related to select component
internal/controller/operator/factory/finalize/cluster.go:82
↓ 4 callersFunctionOnStorageDelete
OnStorageDelete removes all objects related to storage component
internal/controller/operator/factory/finalize/cluster.go:111
↓ 4 callersFunctionPersistentVolumeClaim
PersistentVolumeClaim reconciles PVC object It updates only resource spec other fields are ignored Makes attempt to resize pvc if needed in case of de
internal/controller/operator/factory/reconcile/pvc.go:24
↓ 4 callersMethodPrefixedName
PrefixedName returns prefixed name for the given component kind
api/operator/v1beta1/vmcluster_types.go:167
↓ 4 callersMethodPrefixedName
()
api/operator/v1beta1/vmsingle_types.go:248
↓ 4 callersFunctionRemoveOrphanedSTSs
RemoveOrphanedSTSs removes Deployments detached from given object
internal/controller/operator/factory/finalize/orphaned.go:29
↓ 4 callersFunctionRole
Role reconciles role object
internal/controller/operator/factory/reconcile/rbac.go:57
↓ 4 callersFunctionRoleBinding
RoleBinding reconciles rolebindg object
internal/controller/operator/factory/reconcile/rbac.go:18
↓ 4 callersFunctionRun
Run executes the provided command within this context
test/utils/utils.go:38
↓ 4 callersMethodStart
(stopCh <-chan struct{})
api/client/informers/externalversions/internalinterfaces/factory_interfaces.go:34
↓ 4 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
↓ 4 callersMethodVMAgentName
VMAgentName returns the name of the VMAgent for zone.
api/operator/v1alpha1/vmdistributed_types.go:103
↓ 4 callersMethodVMClusterName
VMClusterName return cluster name for zone
api/operator/v1alpha1/vmdistributed_types.go:115
↓ 4 callersFunctionVMPodScrape
VMPodScrape creates or updates given object
internal/controller/operator/factory/reconcile/vmpodscrape.go:19
↓ 4 callersMethodValidate
()
api/operator/v1beta1/vmalertmanagerconfig_types.go:119
↓ 4 callersMethodaccessScheme
()
api/operator/v1beta1/vmalertmanager_types.go:474
↓ 4 callersFunctionaddSelectorToRelabelingFor
(relabelings []yaml.MapSlice, typeName string, selector metav1.LabelSelector, mustSkipAdd bool)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:550
↓ 4 callersFunctionappendIfNotEmpty
(src []string, key string, origin yaml.MapSlice)
internal/controller/operator/factory/vmauth/vmusers_config.go:385
↓ 4 callersFunctionbuildCRPrefixedName
(cr *vmv1beta1.VMAlertmanagerConfig, name string)
internal/controller/operator/factory/vmalertmanager/config.go:299
↓ 4 callersFunctioncheckRelabelConfigs
(src []*RelabelConfig)
api/operator/v1beta1/vmagent_types.go:696
↓ 4 callersMethodclose
()
cmd/config-reloader/main.go:299
↓ 4 callersFunctioncreateOrUpdateScrapeConfig
(ctx context.Context, rclient client.Client, cr, prevCR *vmv1beta1.VMAgent, childObject client.Object, ac *bui
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:38
↓ 4 callersFunctiongenerateK8SSDConfig
(ac *build.AssetsCache, opts ...generateK8SSDConfigOptions)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:380
↓ 4 callersFunctiongetAssetsCache
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAuth)
internal/controller/operator/factory/vmauth/vmauth.go:378
↓ 4 callersFunctionlistObjectsByListProto
(namespace string, listProto client.ObjectList)
test/e2e/watchnamespace/utils_test.go:99
← previousnext →101–200 of 3,239, ranked by callers