MCPcopy Create free account

hub / github.com/VictoriaMetrics/operator / functions

Functions3,239 in github.com/VictoriaMetrics/operator

↓ 2 callersFunctionbuildAlertmanagerConfigWithCRDs
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAlertmanager, originConfig []byte, ac *build.Asse
internal/controller/operator/factory/vmalertmanager/statefulset.go:602
↓ 2 callersFunctionbuildArgs
(cr *vmv1beta1.VMAlert, ruleConfigMapNames []string, ac *build.AssetsCache)
internal/controller/operator/factory/vmalert/vmalert.go:443
↓ 2 callersMethodbuildConfig
builds vmauth config.
internal/controller/operator/factory/vmauth/vmusers_config.go:37
↓ 2 callersFunctionbuildGossipConfigYAML
builds configuration according to https://prometheus.io/docs/alerting/latest/https/#gossip-traffic
internal/controller/operator/factory/vmalertmanager/config.go:1671
↓ 2 callersFunctionbuildIngressConfig
(cr *vmv1beta1.VMAuth)
internal/controller/operator/factory/vmauth/vmauth.go:473
↓ 2 callersFunctionbuildLBConfigSecretMeta
(cr *vmv1.VTCluster)
internal/controller/operator/factory/vtcluster/vmauth_lb.go:59
↓ 2 callersFunctionbuildLBConfigSecretMeta
(cr *vmv1beta1.VMCluster)
internal/controller/operator/factory/vmcluster/vmcluster.go:1427
↓ 2 callersFunctionbuildLBConfigSecretMeta
(cr *vmv1.VLCluster)
internal/controller/operator/factory/vlcluster/vmauth_lb.go:61
↓ 2 callersFunctionbuildNotifiersArgs
(cr *vmv1beta1.VMAlert, ac *build.AssetsCache)
internal/controller/operator/factory/vmalert/vmalert.go:554
↓ 2 callersFunctionbuildRemoteWriteArgs
(cr *vmv1beta1.VMAgent, ac *build.AssetsCache)
internal/controller/operator/factory/vmagent/vmagent.go:915
↓ 2 callersFunctionbuildRemoteWriteArgs
(cr *vmv1.VLAgent)
internal/controller/operator/factory/vlagent/vlagent.go:531
↓ 2 callersFunctionbuildVMAuthLB
(cr *vmv1alpha1.VMDistributed, vmAgents []*vmv1beta1.VMAgent, vmClusters []*vmv1beta1.VMCluster, excludeIds ..
internal/controller/operator/factory/vmdistributed/vmauth.go:79
↓ 2 callersFunctionbuildWebServerConfigYAML
builds configuration according to https://prometheus.io/docs/alerting/latest/https/#http-traffic
internal/controller/operator/factory/vmalertmanager/config.go:1784
↓ 2 callersFunctioncanBeRemoved
(o client.Object, selector map[string]string, owner *metav1.OwnerReference)
internal/controller/operator/factory/finalize/orphaned.go:157
↓ 2 callersMethodcancelIfNeeded
()
internal/controller/operator/factory/vmdistributed/zone.go:435
↓ 2 callersFunctionconfigReloaderImage
()
test/e2e/upgrade/utils.go:36
↓ 2 callersFunctionconvertEndpoint
(promEndpoint []promv1.Endpoint)
internal/controller/operator/converter/apis.go:204
↓ 2 callersFunctionconvertPodEndpoints
(promPodEnpoints []promv1.PodMetricsEndpoint)
internal/controller/operator/converter/apis.go:337
↓ 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 callersFunctioncreateOrUpdateConfig
createOrUpdateConfig reconcile configuration for vmanomaly and returns configuration consistent hash
internal/controller/operator/factory/vmanomaly/config.go:20
↓ 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:283
↓ 2 callersFunctioncreateOrUpdateLBProxyService
createOrUpdateLBProxyService builds vminsert and vmselect external services to expose vmcluster components for access by vmauth
internal/controller/operator/factory/vmcluster/vmcluster.go:277
↓ 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:289
↓ 2 callersFunctioncreateOrUpdateRelabelConfigsAssets
createOrUpdateRelabelConfigsAssets builds relabeling configs for vmagent at separate configmap, serialized as yaml
internal/controller/operator/factory/vmagent/vmagent.go:789
↓ 2 callersFunctioncreateOrUpdateService
createOrUpdateService creates service for vmalert
internal/controller/operator/factory/vmalert/vmalert.go:46
↓ 2 callersFunctioncreateOrUpdateService
createOrUpdateService creates service for vtsingle
internal/controller/operator/factory/vtsingle/vtsingle.go:283
↓ 2 callersFunctioncreateOrUpdateService
createOrUpdateService creates service for vlsingle
internal/controller/operator/factory/vlsingle/vlsingle.go:292
↓ 2 callersFunctioncreateOrUpdateService
(ctx context.Context, rclient client.Client, cr, prevCR *vmv1beta1.VMAgent)
internal/controller/operator/factory/vmagent/vmagent.go:66
↓ 2 callersFunctioncreateOrUpdateService
(ctx context.Context, rclient client.Client, cr, prevCR *vmv1beta1.VMSingle)
internal/controller/operator/factory/vmsingle/vmsingle.go:329
↓ 2 callersFunctioncreateOrUpdateStreamAggrConfig
createOrUpdateStreamAggrConfig builds stream aggregation configs for vmagent at separate configmap, serialized as yaml
internal/controller/operator/factory/vmagent/vmagent.go:864
↓ 2 callersFunctioncreateSteps
(events types.SpecEvents, entries types.ReportEntries)
test/e2e/suite/allure/result.go:138
↓ 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:228
↓ 2 callersFunctionderegisterObjectByCollector
deregisterObject removes from cache given CR object name with namespace for controller
internal/controller/operator/objects_stat.go:86
↓ 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:681
↓ 2 callersFunctionensureFolderCreated
()
test/e2e/suite/allure/misc.go:77
↓ 2 callersFunctionexpectConditionOkFor
(conds []vmv1beta1.Condition, typeCondtains string)
test/e2e/childobjects/suite_test.go:45
↓ 2 callersFunctionfetchCRDRefURLs
(ctx context.Context, rclient client.Client, refs []vmv1beta1.TargetRef, crdURLCache map[string]string)
internal/controller/operator/factory/vmauth/vmusers_config.go:307
↓ 2 callersFunctionfetchMetricValues
(ctx context.Context, httpClient *http.Client, url, metricName, dimension string)
internal/controller/operator/factory/vmdistributed/util.go:16
↓ 2 callersFunctionfilterForAttachments
(entries types.ReportEntries)
test/e2e/suite/allure/result.go:204
↓ 2 callersFunctiongenPassword
()
internal/controller/operator/factory/vmauth/vmusers_config.go:840
↓ 2 callersFunctiongenURLMaps
generates routing config for given target refs
internal/controller/operator/factory/vmauth/vmusers_config.go:580
↓ 2 callersFunctiongenUserCfg
this function mutates user and fills missing fields, such password or username.
internal/controller/operator/factory/vmauth/vmusers_config.go:763
↓ 2 callersFunctiongenerateNodeScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *parsedObjects, sc *vmv1beta1.VMNodeScrape,
internal/controller/operator/factory/vmagent/nodescrape.go:13
↓ 2 callersFunctiongeneratePodScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *parsedObjects, sc *vmv1beta1.VMPodScrape, e
internal/controller/operator/factory/vmagent/podscrape.go:13
↓ 2 callersFunctiongenerateProbeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *parsedObjects, sc *vmv1beta1.VMProbe, ac *b
internal/controller/operator/factory/vmagent/probe.go:49
↓ 2 callersFunctiongenerateScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, sc *vmv1beta1.VMScrapeConfig, ac *build.AssetsCac
internal/controller/operator/factory/vmagent/scrapeconfig.go:14
↓ 2 callersFunctiongenerateServiceScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *parsedObjects, sc *vmv1beta1.VMServiceScrape
internal/controller/operator/factory/vmagent/servicescrape.go:13
↓ 2 callersFunctiongenerateStaticScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, sc *vmv1beta1.VMStaticScrape, ep *vmv1beta1.Targe
internal/controller/operator/factory/vmagent/staticscrape.go:13
↓ 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:102
↓ 2 callersFunctiongetScrapeDiscoveryRules
getScrapeDiscoveryRules returns the K8s service-discovery rules needed in every watched namespace.
internal/controller/operator/factory/vmagent/rbac.go:17
↓ 2 callersFunctiongetTestClient
(predefinedObjects []runtime.Object, fns *interceptor.Funcs)
internal/controller/operator/factory/k8stools/test_helpers.go:105
↓ 2 callersFunctionhandleReconcileErr
(ctx context.Context, rclient client.Client, object client.Object, originResult ctrl.Result, err error)
internal/controller/operator/controllers.go:140
↓ 2 callersFunctionhasOwnerReference
(owners []metav1.OwnerReference, owner *metav1.OwnerReference)
internal/controller/operator/factory/vmdistributed/vmauth.go:15
↓ 2 callersFunctionhasRemoteWriteSecrets
(cr *vmv1beta1.VMAgent)
internal/controller/operator/factory/vmagent/vmagent.go:897
↓ 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 callersFunctionjitterForDuration
adds 50% jitter to the given duration
internal/controller/operator/factory/reconcile/status.go:176
↓ 2 callersFunctionmakeSpecForVMAuth
(cr *vmv1beta1.VMAuth)
internal/controller/operator/factory/vmauth/vmauth.go:187
↓ 2 callersFunctionmergeAttachMetadataWithScrapeClass
(am *vmv1beta1.AttachMetadata, scrapeClass *vmv1beta1.ScrapeClass)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:834
↓ 2 callersFunctionmergeSpecs
(a, b *T, name string)
internal/controller/operator/factory/vmdistributed/util.go:247
↓ 2 callersFunctionmergeTLSConfigs
(left, right *vmv1beta1.TLSConfig)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:850
↓ 2 callersFunctionmustRouteToJSON
(t *testing.T, r vmv1beta1.SubRoute)
internal/controller/operator/factory/vmalertmanager/config_test.go:24
↓ 2 callersFunctionnewCollector
()
internal/controller/operator/objects_stat.go:45
↓ 2 callersFunctionnewErrRecreate
(ctx context.Context, r client.Object)
internal/controller/operator/factory/reconcile/reconcile.go:120
↓ 2 callersFunctionnewPodSpec
(cr *vmv1.VLAgent)
internal/controller/operator/factory/vlagent/vlagent.go:249
↓ 2 callersFunctionparseNestedRoutes
parseNestedRoutes validates nested routes
api/operator/v1beta1/vmalertmanagerconfig_types.go:254
↓ 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:241
↓ 2 callersFunctionpodStatusesToError
(origin error, pod *corev1.Pod)
internal/controller/operator/factory/reconcile/statefulset.go:423
↓ 2 callersFunctionsecretFromEvent
(obj interface{})
cmd/config-reloader/k8s_watch.go:117
↓ 2 callersMethodselectPodScrapes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmagent/objects.go:91
↓ 2 callersMethodselectProbes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmagent/objects.go:118
↓ 2 callersFunctionselectRules
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAlert)
internal/controller/operator/factory/vmalert/rules.go:95
↓ 2 callersMethodselectServiceScrapes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmagent/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
↓ 2 callersFunctionsetConfigDefaults
(config *rest.Config)
api/client/versioned/typed/operator/v1alpha1/operator_client.go:82
↓ 2 callersFunctionskipLeadingWhitespace
(s string)
internal/controller/operator/factory/vmdistributed/util.go:164
↓ 2 callersFunctionsortStsPodsByID
(src []corev1.Pod)
internal/controller/operator/factory/reconcile/statefulset.go:475
↓ 2 callersFunctionstringMapToMapSlice
(m map[string]string)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:209
↓ 2 callersFunctionupdatePVC
(ctx context.Context, rclient client.Client, existingObj, newObj, prevObj *corev1.PersistentVolumeClaim, owner
internal/controller/operator/factory/reconcile/statefulset_pvc_expand.go:200
↓ 2 callersFunctionupdateSTSPVC
(ctx context.Context, rclient client.Client, sts *appsv1.StatefulSet, prevVCTs []corev1.PersistentVolumeClaim)
internal/controller/operator/factory/reconcile/statefulset_pvc_expand.go:81
↓ 2 callersMethodwaitForEmptyPQ
(ctx context.Context, rclient client.Client, interval time.Duration, clusterIdx int)
internal/controller/operator/factory/vmdistributed/zone.go:297
↓ 2 callersFunctionwaitForPVCReady
(ctx context.Context, rclient client.Client, nsn types.NamespacedName, size resource.Quantity)
internal/controller/operator/factory/reconcile/pvc.go:57
↓ 2 callersFunctionwaitForPodReady
(ctx context.Context, rclient client.Client, nsn types.NamespacedName, desiredRevision string, minReadySeconds
internal/controller/operator/factory/reconcile/statefulset.go:396
↓ 2 callersFunctionwriteFile
(filename string, content []byte)
test/e2e/suite/allure/misc.go:33
↓ 1 callersFunctionAddAttachment
(name string, mimeType MimeType, content []byte)
test/e2e/suite/allure/api.go:13
↓ 1 callersMethodAddRefToObj
AddRefToObj adds reference to given object and return it.
api/operator/v1beta1/vmuser_types.go:157
↓ 1 callersMethodAsListOptions
()
api/operator/v1beta1/vmextra_types.go:483
↓ 1 callersMethodAsNotifiers
AsNotifiers converts VMAlertmanager into VMAlertNotifierSpec
api/operator/v1beta1/vmalertmanager_types.go:435
↓ 1 callersMethodAsOwner
AsOwner returns owner references with current object as owner
api/operator/v1alpha1/vmdistributed_types.go:366
↓ 1 callersMethodAsURL
AsURL implements stub for interface.
api/operator/v1beta1/vmcluster_types.go:877
↓ 1 callersMethodAsURL
AsURL implements stub for interface. nolint:dupl,lll
api/operator/v1/vtcluster_types.go:748
↓ 1 callersMethodAutomountServiceAccountToken
AutomountServiceAccountToken implements reloadable interface
api/operator/v1beta1/vmauth_types.go:741
↓ 1 callersMethodAvailableStorageNodeIDs
AvailableStorageNodeIDs returns ids of the storage nodes for the provided component
api/operator/v1beta1/vmcluster_types.go:718
↓ 1 callersMethodAvailableStorageNodeIDs
AvailableStorageNodeIDs returns ids of the storage nodes for the provided component
api/operator/v1/vlcluster_types.go:779
↓ 1 callersFunctionClusterSelectorLabels
ClusterSelectorLabels defines selector labels for given cluster component kind
api/operator/v1beta1/vmextra_types.go:108
↓ 1 callersFunctionConfigAsMetrics
ConfigAsMetrics exposes major configuration params as prometheus metrics
internal/config/config.go:811
↓ 1 callersMethodConfigSecretName
ConfigSecretName returns configuration secret name for alertmanager
api/operator/v1beta1/vmalertmanager_types.go:357
← previousnext →401–500 of 3,239, ranked by callers