MCPcopy Create free account

hub / github.com/VictoriaMetrics/operator / functions

Functions3,853 in github.com/VictoriaMetrics/operator

↓ 2 callersFunctionaddAttachMetadata
(dst yaml.MapSlice, am *vmv1beta1.AttachMetadata, role string)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:128
↓ 2 callersMethodaddAttachment
(attachment *attachment)
test/e2e/suite/allure/result.go:58
↓ 2 callersMethodaddAuthCredentialsBuildSecrets
(ac *build.AssetsCache)
internal/controller/operator/factory/vmauth/vmusers_config.go:197
↓ 2 callersFunctionaddConfigTemplates
addConfigTemplates adds external templates to the given based configuration
internal/controller/operator/factory/vmalertmanager/config.go:205
↓ 2 callersFunctionaddURLMapCommonToYaml
(dst yaml.MapSlice, opt vmv1beta1.URLMapCommon, isDefaultRoute bool)
internal/controller/operator/factory/vmauth/vmusers_config.go:518
↓ 2 callersFunctionaddUserConfigOptionToYaml
(dst yaml.MapSlice, opt vmv1beta1.VMUserConfigOptions, cr *vmv1beta1.VMAuth, ac *build.AssetsCache)
internal/controller/operator/factory/vmauth/vmusers_config.go:556
↓ 2 callersMethodasTLSConfig
asTLSConfig converts the flat tls* keys to the operator's nested TLSConfig, or nil if none were set.
internal/converter/converter.go:415
↓ 2 callersFunctionbuildAlertmanagerConfigWithCRDs
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAlertmanager, originConfig []byte, ac *build.Asse
internal/controller/operator/factory/vmalertmanager/statefulset.go:595
↓ 2 callersFunctionbuildArgs
(cr *vmv1beta1.VMAlert, ruleConfigMapNames []string, ac *build.AssetsCache)
internal/controller/operator/factory/vmalert/vmalert.go:512
↓ 2 callersMethodbuildConfig
builds vmauth config.
internal/controller/operator/factory/vmauth/vmusers_config.go:69
↓ 2 callersFunctionbuildGossipConfigYAML
builds configuration according to https://prometheus.io/docs/alerting/latest/https/#gossip-traffic
internal/controller/operator/factory/vmalertmanager/config.go:1563
↓ 2 callersFunctionbuildIngressConfig
(cr *vmv1beta1.VMAuth)
internal/controller/operator/factory/vmauth/vmauth.go:511
↓ 2 callersFunctionbuildLBConfigSecretMeta
(cr *vmv1.VTCluster)
internal/controller/operator/factory/vtcluster/vmauth_lb.go:105
↓ 2 callersFunctionbuildLBConfigSecretMeta
(cr *vmv1beta1.VMCluster)
internal/controller/operator/factory/vmcluster/vmcluster.go:1559
↓ 2 callersFunctionbuildLBConfigSecretMeta
(cr *vmv1.VLCluster)
internal/controller/operator/factory/vlcluster/vmauth_lb.go:107
↓ 2 callersFunctionbuildNotifiersArgs
(cr *vmv1beta1.VMAlert, ac *build.AssetsCache)
internal/controller/operator/factory/vmalert/vmalert.go:623
↓ 2 callersFunctionbuildRemoteWriteArgs
(cr *vmv1.VLAgent)
internal/controller/operator/factory/vlagent/vlagent.go:562
↓ 2 callersFunctionbuildVMAgentServiceScrape
(cr *vmv1beta1.VMAgent, svc *corev1.Service)
internal/controller/operator/factory/vmagent/vmagent.go:54
↓ 2 callersFunctionbuildWebServerConfigYAML
builds configuration according to https://prometheus.io/docs/alerting/latest/https/#http-traffic
internal/controller/operator/factory/vmalertmanager/config.go:1647
↓ 2 callersFunctioncanBeRemoved
(o client.Object, selector map[string]string, owner *metav1.OwnerReference)
internal/controller/operator/factory/finalize/orphaned.go:167
↓ 2 callersMethodcancelIfNeeded
()
internal/podutil/util.go:151
↓ 2 callersFunctionchangedKeysWithSizes
changedKeysWithSizes returns the sorted keys whose values differ between desired and current, annotated with the value byte size on each side. Values
internal/controller/operator/factory/reconcile/configmap.go:64
↓ 2 callersFunctionchildConditionType
(parentObjectName string)
internal/controller/operator/factory/reconcile/status.go:37
↓ 2 callersMethodclusterObjects
()
internal/controller/operator/factory/vldistributed/zone.go:78
↓ 2 callersFunctionconfigReloaderImage
()
test/e2e/upgrade/utils.go:36
↓ 2 callersFunctionconvertEndpoint
(ctx context.Context, promEndpoint []promv1.Endpoint)
internal/controller/operator/factory/converter/apis.go:203
↓ 2 callersFunctionconvertHTTPAuth
convertHTTPAuth converts a chart-shaped HTTP auth block into the operator's HTTPAuth, returning a Secret for any plaintext credential found (nil if no
internal/converter/converter.go:244
↓ 2 callersFunctionconvertPodEndpoints
(ctx context.Context, promPodEnpoints []promv1.PodMetricsEndpoint)
internal/controller/operator/factory/converter/apis.go:336
↓ 2 callersFunctionconvertVLAgentRemoteWrite
(items []VLAgentRemoteWriteValues)
internal/converter/converter.go:496
↓ 2 callersFunctioncreateK8sAPIAccess
createK8sAPIAccess creates RBAC access rules for vmagent. namespaces is the list of watched namespaces; an empty slice means cluster-wide access.
internal/controller/operator/factory/vmagent/rbac.go:90
↓ 2 callersFunctioncreateK8sAPIAccess
createK8sAPIAccess - creates RBAC access rules for vlagent
internal/controller/operator/factory/vlagent/rbac.go:18
↓ 2 callersFunctioncreateK8sAPIAccess
createK8sAPIAccess creates RBAC access rules for vmsingle. namespaces is the list of watched namespaces; an empty slice means cluster-wide access.
internal/controller/operator/factory/vmsingle/rbac.go:83
↓ 2 callersFunctioncreateOrUpdateLBProxyService
createOrUpdateLBProxyService builds vtinsert and vtselect external services to expose vtcluster components for access by vmauth
internal/controller/operator/factory/vtcluster/vmauth_lb.go:329
↓ 2 callersFunctioncreateOrUpdateLBProxyService
createOrUpdateLBProxyService builds vminsert and vmselect external services to expose vmcluster components for access by vmauth
internal/controller/operator/factory/vmcluster/vmcluster.go:296
↓ 2 callersFunctioncreateOrUpdateLBProxyService
createOrUpdateLBProxyService builds vlinsert and vlselect external services to expose vlcluster components for access by vmauth
internal/controller/operator/factory/vlcluster/vmauth_lb.go:336
↓ 2 callersFunctioncreateOrUpdateRelabelConfigsAssets
createOrUpdateRelabelConfigsAssets builds relabeling configs for vmagent at separate configmap, serialized as yaml.
internal/controller/operator/factory/vmagent/vmagent.go:895
↓ 2 callersFunctioncreateOrUpdateService
createOrUpdateService creates service for vmalert
internal/controller/operator/factory/vmalert/vmalert.go:55
↓ 2 callersFunctioncreateOrUpdateService
createOrUpdateService creates service for vtsingle
internal/controller/operator/factory/vtsingle/vtsingle.go:324
↓ 2 callersFunctioncreateOrUpdateService
createOrUpdateService creates service for vlsingle
internal/controller/operator/factory/vlsingle/vlsingle.go:333
↓ 2 callersFunctioncreateOrUpdateService
(ctx context.Context, rclient client.Client, cr, prevCR *vmv1beta1.VMAgent)
internal/controller/operator/factory/vmagent/vmagent.go:76
↓ 2 callersFunctioncreateOrUpdateService
(ctx context.Context, rclient client.Client, cr, prevCR *vmv1beta1.VMSingle)
internal/controller/operator/factory/vmsingle/vmsingle.go:522
↓ 2 callersFunctioncreateSteps
(events types.SpecEvents, entries types.ReportEntries)
test/e2e/suite/allure/result.go:138
↓ 2 callersFunctioncreateVMAuth
(ctx context.Context, wg *sync.WaitGroup, k8sClient client.Client, name, ns string)
test/e2e/utils_test.go:336
↓ 2 callersFunctiondeduplicateRules
deduplicateRules - takes list of vmRules and modifies it by removing duplicates. possible duplicates: group name across single vmRule. group might inc
internal/controller/operator/factory/vmalert/rules.go:251
↓ 2 callersFunctionderegisterObjectByCollector
deregisterObject removes from cache given CR object name with namespace for controller
internal/controller/operator/objects_stat.go:141
↓ 2 callersFunctiondiscoverNamespaces
discoverNamespaces select namespaces by given label selector
internal/controller/operator/factory/k8stools/selectors.go:67
↓ 2 callersFunctiondiscoverNotifiersIfNeeded
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAlert)
internal/controller/operator/factory/vmalert/vmalert.go:756
↓ 2 callersFunctionensureFolderCreated
()
test/e2e/suite/allure/misc.go:77
↓ 2 callersFunctionexpectConditionOkFor
(conds []vmv1beta1.Condition, typeCondtains string)
test/e2e/childobjects/suite_test.go:45
↓ 2 callersMethodexternalLabels
(defaultLabelValue string)
api/operator/v1beta1/common_scrapeparams.go:682
↓ 2 callersFunctionfilterForAttachments
(entries types.ReportEntries)
test/e2e/suite/allure/result.go:204
↓ 2 callersFunctiongenPassword
()
internal/controller/operator/factory/vmauth/vmusers_config.go:990
↓ 2 callersFunctiongenURLMaps
generates routing config for given target refs
internal/controller/operator/factory/vmauth/vmusers_config.go:646
↓ 2 callersFunctiongenUserCfg
this function mutates user and fills missing fields, such password or username.
internal/controller/operator/factory/vmauth/vmusers_config.go:869
↓ 2 callersFunctiongenerateNodeScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *ParsedObjects, sc *vmv1beta1.VMNodeScrape,
internal/controller/operator/factory/vmscrapes/nodescrape.go:13
↓ 2 callersFunctiongeneratePodScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *ParsedObjects, sc *vmv1beta1.VMPodScrape, e
internal/controller/operator/factory/vmscrapes/podscrape.go:13
↓ 2 callersFunctiongenerateProbeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *ParsedObjects, sc *vmv1beta1.VMProbe, ac *b
internal/controller/operator/factory/vmscrapes/probe.go:49
↓ 2 callersFunctiongenerateScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, sc *vmv1beta1.VMScrapeConfig, ac *build.AssetsCac
internal/controller/operator/factory/vmscrapes/scrapeconfig.go:14
↓ 2 callersFunctiongenerateServiceScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *ParsedObjects, sc *vmv1beta1.VMServiceScrape
internal/controller/operator/factory/vmscrapes/servicescrape.go:13
↓ 2 callersFunctiongenerateStaticScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, sc *vmv1beta1.VMStaticScrape, ep *vmv1beta1.Targe
internal/controller/operator/factory/vmscrapes/staticscrape.go:13
↓ 2 callersFunctiongetAssetsCache
(ctx context.Context, rclient client.Client, cr *vmv1.VMAnomaly)
internal/controller/operator/factory/vmanomaly/statefulset.go:352
↓ 2 callersFunctiongetFirstValue
(args map[string]string, name string)
api/operator/v1beta1/vmextra_types.go:190
↓ 2 callersFunctiongetLatestPods
(ctx context.Context, rclient client.Client, obj client.Object)
test/e2e/utils_test.go:34
↓ 2 callersFunctiongetPVCByName
(vcts []corev1.PersistentVolumeClaim, name string)
internal/controller/operator/factory/reconcile/statefulset_pvc_expand.go:72
↓ 2 callersFunctiongetRevisionHistoryLimit
(ctx context.Context, rclient client.Client, name types.NamespacedName)
test/e2e/utils_test.go:119
↓ 2 callersFunctiongetScrapeDiscoveryRules
getScrapeDiscoveryRules returns the K8s service-discovery rules needed in every watched namespace.
internal/controller/operator/factory/vmagent/rbac.go:17
↓ 2 callersFunctiongetScrapeDiscoveryRules
()
internal/controller/operator/factory/vmsingle/rbac.go:16
↓ 2 callersFunctiongetTestClient
(predefinedObjects []runtime.Object, fns *interceptor.Funcs)
internal/controller/operator/factory/k8stools/test_helpers.go:110
↓ 2 callersMethodisNodeScrapeUnmanaged
isNodeScrapeUnmanaged checks if scraping agent should managed any VMNodeScrape objects
api/operator/v1beta1/common_scrapeparams.go:731
↓ 2 callersMethodisPodScrapeUnmanaged
isUnmanaged checks if scraping agent should managed any VMPodScrape objects
api/operator/v1beta1/common_scrapeparams.go:749
↓ 2 callersMethodisProbeUnmanaged
isProbeUnmanaged checks if scraping agent should managed any VMProbe objects
api/operator/v1beta1/common_scrapeparams.go:758
↓ 2 callersFunctionisSTSRecreateRequired
isSTSRecreateRequired checks whether the StatefulSet requires recreation and whether pods must be recreated. There are three different cases: 1. sts's
internal/controller/operator/factory/reconcile/statefulset_pvc_expand.go:36
↓ 2 callersMethodisScrapeConfigUnmanaged
isScrapeConfigUnmanaged checks if scraping agent should managed any VMScrapeConfig objects
api/operator/v1beta1/common_scrapeparams.go:776
↓ 2 callersMethodisServiceScrapeUnmanaged
isServiceScrapeUnmanaged checks if scraping agent should managed any VMServiceScrape objects
api/operator/v1beta1/common_scrapeparams.go:740
↓ 2 callersMethodisSet
isSet reports whether any flat tls* key was provided.
internal/converter/converter.go:410
↓ 2 callersMethodisStaticScrapeUnmanaged
isStaticScrapeUnmanaged checks if scraping agent should managed any VMStaticScrape objects
api/operator/v1beta1/common_scrapeparams.go:767
↓ 2 callersMethodisUnmanaged
isUnmanaged checks if object should managed any config objects
api/operator/v1beta1/common_scrapeparams.go:717
↓ 2 callersFunctionisVMAuthEnabled
(cr *vmv1alpha1.VLDistributed)
internal/controller/operator/factory/vldistributed/zone.go:370
↓ 2 callersFunctionjitterForDuration
adds 50% jitter to the given duration
internal/controller/operator/factory/reconcile/status.go:379
↓ 2 callersFunctionmakeSpecForVMAuth
(cr *vmv1beta1.VMAuth)
internal/controller/operator/factory/vmauth/vmauth.go:201
↓ 2 callersFunctionmaybeDecompress
maybeDecompress returns data decompressed if gzip magic is detected, otherwise as-is.
cmd/config-reloader/file_watch.go:332
↓ 2 callersFunctionmergeAttachMetadataWithScrapeClass
(am *vmv1beta1.AttachMetadata, scrapeClass *vmv1beta1.ScrapeClass)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:696
↓ 2 callersFunctionmergeMetaInternal
(existingObj, newObj client.Object, prevMeta *metav1.ObjectMeta, owner *metav1.OwnerReference, shouldRemoveFin
internal/controller/operator/factory/reconcile/reconcile.go:126
↓ 2 callersFunctionmergeTLSConfigs
(left, right *vmv1beta1.TLSConfig)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:712
↓ 2 callersFunctionmustRouteToJSON
(t *testing.T, r vmv1beta1.SubRoute)
internal/controller/operator/factory/vmalertmanager/config_test.go:24
↓ 2 callersFunctionnewErrRecreate
(ctx context.Context, r client.Object)
internal/controller/operator/factory/reconcile/reconcile.go:160
↓ 2 callersFunctionnewPodSpec
(cr *vmv1.VLAgent)
internal/controller/operator/factory/vlagent/vlagent.go:271
↓ 2 callersFunctionnewPodSpec
(ctx context.Context, cr *vmv1beta1.VMSingle, extraConfigSecretCount int)
internal/controller/operator/factory/vmsingle/vmsingle.go:191
↓ 2 callersFunctionnewStsForAlertManager
(cr *vmv1beta1.VMAlertmanager)
internal/controller/operator/factory/vmalertmanager/statefulset.go:53
↓ 2 callersFunctionparseNestedRoutes
parseNestedRoutes validates nested routes
api/operator/v1beta1/vmalertmanagerconfig_types.go:350
↓ 2 callersFunctionperformRollingUpdateOnSts
we perform rolling update on sts by manually evicting pods one by one or in batches we check sts revision (kubernetes controller-manager is responsibl
internal/controller/operator/factory/reconcile/statefulset.go:257
↓ 2 callersFunctionpodStatusesToError
(origin error, pod *corev1.Pod)
internal/controller/operator/factory/reconcile/statefulset.go:439
↓ 2 callersFunctionscrapeGauge
scrapeGauge renders set and returns the value of the sample matching configreloader_reload_content_hash{key="key"}, or nil if no such sample was writt
cmd/config-reloader/content_hash_test.go:65
↓ 2 callersFunctionsecretFromEvent
(obj interface{})
cmd/config-reloader/k8s_watch.go:123
↓ 2 callersMethodselectPodScrapes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmscrapes/objects.go:91
↓ 2 callersMethodselectProbes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmscrapes/objects.go:118
↓ 2 callersFunctionselectRules
selectRules selects rule groups for cr. When hasNotifiers is false, alerting rules are dropped from each group (vmalert has nowhere to send them); gro
internal/controller/operator/factory/vmalert/rules.go:98
↓ 2 callersMethodselectServiceScrapes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmscrapes/objects.go:205
↓ 2 callersFunctionsetConfigDefaults
(config *rest.Config)
api/client/versioned/typed/operator/v1beta1/operator_client.go:157
↓ 2 callersFunctionsetConfigDefaults
(config *rest.Config)
api/client/versioned/typed/operator/v1/operator_client.go:107
← previousnext →501–600 of 3,853, ranked by callers