Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/VictoriaMetrics/operator
/ functions
Functions
3,853 in github.com/VictoriaMetrics/operator
⨍
Functions
3,853
◇
Types & classes
1,071
↓ 2 callers
Function
addAttachMetadata
(dst yaml.MapSlice, am *vmv1beta1.AttachMetadata, role string)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:128
↓ 2 callers
Method
addAttachment
(attachment *attachment)
test/e2e/suite/allure/result.go:58
↓ 2 callers
Method
addAuthCredentialsBuildSecrets
(ac *build.AssetsCache)
internal/controller/operator/factory/vmauth/vmusers_config.go:197
↓ 2 callers
Function
addConfigTemplates
addConfigTemplates adds external templates to the given based configuration
internal/controller/operator/factory/vmalertmanager/config.go:205
↓ 2 callers
Function
addURLMapCommonToYaml
(dst yaml.MapSlice, opt vmv1beta1.URLMapCommon, isDefaultRoute bool)
internal/controller/operator/factory/vmauth/vmusers_config.go:518
↓ 2 callers
Function
addUserConfigOptionToYaml
(dst yaml.MapSlice, opt vmv1beta1.VMUserConfigOptions, cr *vmv1beta1.VMAuth, ac *build.AssetsCache)
internal/controller/operator/factory/vmauth/vmusers_config.go:556
↓ 2 callers
Method
asTLSConfig
asTLSConfig converts the flat tls* keys to the operator's nested TLSConfig, or nil if none were set.
internal/converter/converter.go:415
↓ 2 callers
Function
buildAlertmanagerConfigWithCRDs
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAlertmanager, originConfig []byte, ac *build.Asse
internal/controller/operator/factory/vmalertmanager/statefulset.go:595
↓ 2 callers
Function
buildArgs
(cr *vmv1beta1.VMAlert, ruleConfigMapNames []string, ac *build.AssetsCache)
internal/controller/operator/factory/vmalert/vmalert.go:512
↓ 2 callers
Method
buildConfig
builds vmauth config.
internal/controller/operator/factory/vmauth/vmusers_config.go:69
↓ 2 callers
Function
buildGossipConfigYAML
builds configuration according to https://prometheus.io/docs/alerting/latest/https/#gossip-traffic
internal/controller/operator/factory/vmalertmanager/config.go:1563
↓ 2 callers
Function
buildIngressConfig
(cr *vmv1beta1.VMAuth)
internal/controller/operator/factory/vmauth/vmauth.go:511
↓ 2 callers
Function
buildLBConfigSecretMeta
(cr *vmv1.VTCluster)
internal/controller/operator/factory/vtcluster/vmauth_lb.go:105
↓ 2 callers
Function
buildLBConfigSecretMeta
(cr *vmv1beta1.VMCluster)
internal/controller/operator/factory/vmcluster/vmcluster.go:1559
↓ 2 callers
Function
buildLBConfigSecretMeta
(cr *vmv1.VLCluster)
internal/controller/operator/factory/vlcluster/vmauth_lb.go:107
↓ 2 callers
Function
buildNotifiersArgs
(cr *vmv1beta1.VMAlert, ac *build.AssetsCache)
internal/controller/operator/factory/vmalert/vmalert.go:623
↓ 2 callers
Function
buildRemoteWriteArgs
(cr *vmv1.VLAgent)
internal/controller/operator/factory/vlagent/vlagent.go:562
↓ 2 callers
Function
buildVMAgentServiceScrape
(cr *vmv1beta1.VMAgent, svc *corev1.Service)
internal/controller/operator/factory/vmagent/vmagent.go:54
↓ 2 callers
Function
buildWebServerConfigYAML
builds configuration according to https://prometheus.io/docs/alerting/latest/https/#http-traffic
internal/controller/operator/factory/vmalertmanager/config.go:1647
↓ 2 callers
Function
canBeRemoved
(o client.Object, selector map[string]string, owner *metav1.OwnerReference)
internal/controller/operator/factory/finalize/orphaned.go:167
↓ 2 callers
Method
cancelIfNeeded
()
internal/podutil/util.go:151
↓ 2 callers
Function
changedKeysWithSizes
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 callers
Function
childConditionType
(parentObjectName string)
internal/controller/operator/factory/reconcile/status.go:37
↓ 2 callers
Method
clusterObjects
()
internal/controller/operator/factory/vldistributed/zone.go:78
↓ 2 callers
Function
configReloaderImage
()
test/e2e/upgrade/utils.go:36
↓ 2 callers
Function
convertEndpoint
(ctx context.Context, promEndpoint []promv1.Endpoint)
internal/controller/operator/factory/converter/apis.go:203
↓ 2 callers
Function
convertHTTPAuth
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 callers
Function
convertPodEndpoints
(ctx context.Context, promPodEnpoints []promv1.PodMetricsEndpoint)
internal/controller/operator/factory/converter/apis.go:336
↓ 2 callers
Function
convertVLAgentRemoteWrite
(items []VLAgentRemoteWriteValues)
internal/converter/converter.go:496
↓ 2 callers
Function
createK8sAPIAccess
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 callers
Function
createK8sAPIAccess
createK8sAPIAccess - creates RBAC access rules for vlagent
internal/controller/operator/factory/vlagent/rbac.go:18
↓ 2 callers
Function
createK8sAPIAccess
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 callers
Function
createOrUpdateLBProxyService
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 callers
Function
createOrUpdateLBProxyService
createOrUpdateLBProxyService builds vminsert and vmselect external services to expose vmcluster components for access by vmauth
internal/controller/operator/factory/vmcluster/vmcluster.go:296
↓ 2 callers
Function
createOrUpdateLBProxyService
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 callers
Function
createOrUpdateRelabelConfigsAssets
createOrUpdateRelabelConfigsAssets builds relabeling configs for vmagent at separate configmap, serialized as yaml.
internal/controller/operator/factory/vmagent/vmagent.go:895
↓ 2 callers
Function
createOrUpdateService
createOrUpdateService creates service for vmalert
internal/controller/operator/factory/vmalert/vmalert.go:55
↓ 2 callers
Function
createOrUpdateService
createOrUpdateService creates service for vtsingle
internal/controller/operator/factory/vtsingle/vtsingle.go:324
↓ 2 callers
Function
createOrUpdateService
createOrUpdateService creates service for vlsingle
internal/controller/operator/factory/vlsingle/vlsingle.go:333
↓ 2 callers
Function
createOrUpdateService
(ctx context.Context, rclient client.Client, cr, prevCR *vmv1beta1.VMAgent)
internal/controller/operator/factory/vmagent/vmagent.go:76
↓ 2 callers
Function
createOrUpdateService
(ctx context.Context, rclient client.Client, cr, prevCR *vmv1beta1.VMSingle)
internal/controller/operator/factory/vmsingle/vmsingle.go:522
↓ 2 callers
Function
createSteps
(events types.SpecEvents, entries types.ReportEntries)
test/e2e/suite/allure/result.go:138
↓ 2 callers
Function
createVMAuth
(ctx context.Context, wg *sync.WaitGroup, k8sClient client.Client, name, ns string)
test/e2e/utils_test.go:336
↓ 2 callers
Function
deduplicateRules
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 callers
Function
deregisterObjectByCollector
deregisterObject removes from cache given CR object name with namespace for controller
internal/controller/operator/objects_stat.go:141
↓ 2 callers
Function
discoverNamespaces
discoverNamespaces select namespaces by given label selector
internal/controller/operator/factory/k8stools/selectors.go:67
↓ 2 callers
Function
discoverNotifiersIfNeeded
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAlert)
internal/controller/operator/factory/vmalert/vmalert.go:756
↓ 2 callers
Function
ensureFolderCreated
()
test/e2e/suite/allure/misc.go:77
↓ 2 callers
Function
expectConditionOkFor
(conds []vmv1beta1.Condition, typeCondtains string)
test/e2e/childobjects/suite_test.go:45
↓ 2 callers
Method
externalLabels
(defaultLabelValue string)
api/operator/v1beta1/common_scrapeparams.go:682
↓ 2 callers
Function
filterForAttachments
(entries types.ReportEntries)
test/e2e/suite/allure/result.go:204
↓ 2 callers
Function
genPassword
()
internal/controller/operator/factory/vmauth/vmusers_config.go:990
↓ 2 callers
Function
genURLMaps
generates routing config for given target refs
internal/controller/operator/factory/vmauth/vmusers_config.go:646
↓ 2 callers
Function
genUserCfg
this function mutates user and fills missing fields, such password or username.
internal/controller/operator/factory/vmauth/vmusers_config.go:869
↓ 2 callers
Function
generateNodeScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *ParsedObjects, sc *vmv1beta1.VMNodeScrape,
internal/controller/operator/factory/vmscrapes/nodescrape.go:13
↓ 2 callers
Function
generatePodScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *ParsedObjects, sc *vmv1beta1.VMPodScrape, e
internal/controller/operator/factory/vmscrapes/podscrape.go:13
↓ 2 callers
Function
generateProbeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *ParsedObjects, sc *vmv1beta1.VMProbe, ac *b
internal/controller/operator/factory/vmscrapes/probe.go:49
↓ 2 callers
Function
generateScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, sc *vmv1beta1.VMScrapeConfig, ac *build.AssetsCac
internal/controller/operator/factory/vmscrapes/scrapeconfig.go:14
↓ 2 callers
Function
generateServiceScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *ParsedObjects, sc *vmv1beta1.VMServiceScrape
internal/controller/operator/factory/vmscrapes/servicescrape.go:13
↓ 2 callers
Function
generateStaticScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, sc *vmv1beta1.VMStaticScrape, ep *vmv1beta1.Targe
internal/controller/operator/factory/vmscrapes/staticscrape.go:13
↓ 2 callers
Function
getAssetsCache
(ctx context.Context, rclient client.Client, cr *vmv1.VMAnomaly)
internal/controller/operator/factory/vmanomaly/statefulset.go:352
↓ 2 callers
Function
getFirstValue
(args map[string]string, name string)
api/operator/v1beta1/vmextra_types.go:190
↓ 2 callers
Function
getLatestPods
(ctx context.Context, rclient client.Client, obj client.Object)
test/e2e/utils_test.go:34
↓ 2 callers
Function
getPVCByName
(vcts []corev1.PersistentVolumeClaim, name string)
internal/controller/operator/factory/reconcile/statefulset_pvc_expand.go:72
↓ 2 callers
Function
getRevisionHistoryLimit
(ctx context.Context, rclient client.Client, name types.NamespacedName)
test/e2e/utils_test.go:119
↓ 2 callers
Function
getScrapeDiscoveryRules
getScrapeDiscoveryRules returns the K8s service-discovery rules needed in every watched namespace.
internal/controller/operator/factory/vmagent/rbac.go:17
↓ 2 callers
Function
getScrapeDiscoveryRules
()
internal/controller/operator/factory/vmsingle/rbac.go:16
↓ 2 callers
Function
getTestClient
(predefinedObjects []runtime.Object, fns *interceptor.Funcs)
internal/controller/operator/factory/k8stools/test_helpers.go:110
↓ 2 callers
Method
isNodeScrapeUnmanaged
isNodeScrapeUnmanaged checks if scraping agent should managed any VMNodeScrape objects
api/operator/v1beta1/common_scrapeparams.go:731
↓ 2 callers
Method
isPodScrapeUnmanaged
isUnmanaged checks if scraping agent should managed any VMPodScrape objects
api/operator/v1beta1/common_scrapeparams.go:749
↓ 2 callers
Method
isProbeUnmanaged
isProbeUnmanaged checks if scraping agent should managed any VMProbe objects
api/operator/v1beta1/common_scrapeparams.go:758
↓ 2 callers
Function
isSTSRecreateRequired
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 callers
Method
isScrapeConfigUnmanaged
isScrapeConfigUnmanaged checks if scraping agent should managed any VMScrapeConfig objects
api/operator/v1beta1/common_scrapeparams.go:776
↓ 2 callers
Method
isServiceScrapeUnmanaged
isServiceScrapeUnmanaged checks if scraping agent should managed any VMServiceScrape objects
api/operator/v1beta1/common_scrapeparams.go:740
↓ 2 callers
Method
isSet
isSet reports whether any flat tls* key was provided.
internal/converter/converter.go:410
↓ 2 callers
Method
isStaticScrapeUnmanaged
isStaticScrapeUnmanaged checks if scraping agent should managed any VMStaticScrape objects
api/operator/v1beta1/common_scrapeparams.go:767
↓ 2 callers
Method
isUnmanaged
isUnmanaged checks if object should managed any config objects
api/operator/v1beta1/common_scrapeparams.go:717
↓ 2 callers
Function
isVMAuthEnabled
(cr *vmv1alpha1.VLDistributed)
internal/controller/operator/factory/vldistributed/zone.go:370
↓ 2 callers
Function
jitterForDuration
adds 50% jitter to the given duration
internal/controller/operator/factory/reconcile/status.go:379
↓ 2 callers
Function
makeSpecForVMAuth
(cr *vmv1beta1.VMAuth)
internal/controller/operator/factory/vmauth/vmauth.go:201
↓ 2 callers
Function
maybeDecompress
maybeDecompress returns data decompressed if gzip magic is detected, otherwise as-is.
cmd/config-reloader/file_watch.go:332
↓ 2 callers
Function
mergeAttachMetadataWithScrapeClass
(am *vmv1beta1.AttachMetadata, scrapeClass *vmv1beta1.ScrapeClass)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:696
↓ 2 callers
Function
mergeMetaInternal
(existingObj, newObj client.Object, prevMeta *metav1.ObjectMeta, owner *metav1.OwnerReference, shouldRemoveFin
internal/controller/operator/factory/reconcile/reconcile.go:126
↓ 2 callers
Function
mergeTLSConfigs
(left, right *vmv1beta1.TLSConfig)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:712
↓ 2 callers
Function
mustRouteToJSON
(t *testing.T, r vmv1beta1.SubRoute)
internal/controller/operator/factory/vmalertmanager/config_test.go:24
↓ 2 callers
Function
newErrRecreate
(ctx context.Context, r client.Object)
internal/controller/operator/factory/reconcile/reconcile.go:160
↓ 2 callers
Function
newPodSpec
(cr *vmv1.VLAgent)
internal/controller/operator/factory/vlagent/vlagent.go:271
↓ 2 callers
Function
newPodSpec
(ctx context.Context, cr *vmv1beta1.VMSingle, extraConfigSecretCount int)
internal/controller/operator/factory/vmsingle/vmsingle.go:191
↓ 2 callers
Function
newStsForAlertManager
(cr *vmv1beta1.VMAlertmanager)
internal/controller/operator/factory/vmalertmanager/statefulset.go:53
↓ 2 callers
Function
parseNestedRoutes
parseNestedRoutes validates nested routes
api/operator/v1beta1/vmalertmanagerconfig_types.go:350
↓ 2 callers
Function
performRollingUpdateOnSts
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 callers
Function
podStatusesToError
(origin error, pod *corev1.Pod)
internal/controller/operator/factory/reconcile/statefulset.go:439
↓ 2 callers
Function
scrapeGauge
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 callers
Function
secretFromEvent
(obj interface{})
cmd/config-reloader/k8s_watch.go:123
↓ 2 callers
Method
selectPodScrapes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmscrapes/objects.go:91
↓ 2 callers
Method
selectProbes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmscrapes/objects.go:118
↓ 2 callers
Function
selectRules
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 callers
Method
selectServiceScrapes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmscrapes/objects.go:205
↓ 2 callers
Function
setConfigDefaults
(config *rest.Config)
api/client/versioned/typed/operator/v1beta1/operator_client.go:157
↓ 2 callers
Function
setConfigDefaults
(config *rest.Config)
api/client/versioned/typed/operator/v1/operator_client.go:107
← previous
next →
501–600 of 3,853, ranked by callers