Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/VictoriaMetrics/operator
/ functions
Functions
3,239 in github.com/VictoriaMetrics/operator
⨍
Functions
3,239
◇
Types & classes
909
↓ 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:602
↓ 2 callers
Function
buildArgs
(cr *vmv1beta1.VMAlert, ruleConfigMapNames []string, ac *build.AssetsCache)
internal/controller/operator/factory/vmalert/vmalert.go:443
↓ 2 callers
Method
buildConfig
builds vmauth config.
internal/controller/operator/factory/vmauth/vmusers_config.go:37
↓ 2 callers
Function
buildGossipConfigYAML
builds configuration according to https://prometheus.io/docs/alerting/latest/https/#gossip-traffic
internal/controller/operator/factory/vmalertmanager/config.go:1671
↓ 2 callers
Function
buildIngressConfig
(cr *vmv1beta1.VMAuth)
internal/controller/operator/factory/vmauth/vmauth.go:473
↓ 2 callers
Function
buildLBConfigSecretMeta
(cr *vmv1.VTCluster)
internal/controller/operator/factory/vtcluster/vmauth_lb.go:59
↓ 2 callers
Function
buildLBConfigSecretMeta
(cr *vmv1beta1.VMCluster)
internal/controller/operator/factory/vmcluster/vmcluster.go:1427
↓ 2 callers
Function
buildLBConfigSecretMeta
(cr *vmv1.VLCluster)
internal/controller/operator/factory/vlcluster/vmauth_lb.go:61
↓ 2 callers
Function
buildNotifiersArgs
(cr *vmv1beta1.VMAlert, ac *build.AssetsCache)
internal/controller/operator/factory/vmalert/vmalert.go:554
↓ 2 callers
Function
buildRemoteWriteArgs
(cr *vmv1beta1.VMAgent, ac *build.AssetsCache)
internal/controller/operator/factory/vmagent/vmagent.go:915
↓ 2 callers
Function
buildRemoteWriteArgs
(cr *vmv1.VLAgent)
internal/controller/operator/factory/vlagent/vlagent.go:531
↓ 2 callers
Function
buildVMAuthLB
(cr *vmv1alpha1.VMDistributed, vmAgents []*vmv1beta1.VMAgent, vmClusters []*vmv1beta1.VMCluster, excludeIds ..
internal/controller/operator/factory/vmdistributed/vmauth.go:79
↓ 2 callers
Function
buildWebServerConfigYAML
builds configuration according to https://prometheus.io/docs/alerting/latest/https/#http-traffic
internal/controller/operator/factory/vmalertmanager/config.go:1784
↓ 2 callers
Function
canBeRemoved
(o client.Object, selector map[string]string, owner *metav1.OwnerReference)
internal/controller/operator/factory/finalize/orphaned.go:157
↓ 2 callers
Method
cancelIfNeeded
()
internal/controller/operator/factory/vmdistributed/zone.go:435
↓ 2 callers
Function
configReloaderImage
()
test/e2e/upgrade/utils.go:36
↓ 2 callers
Function
convertEndpoint
(promEndpoint []promv1.Endpoint)
internal/controller/operator/converter/apis.go:204
↓ 2 callers
Function
convertPodEndpoints
(promPodEnpoints []promv1.PodMetricsEndpoint)
internal/controller/operator/converter/apis.go:337
↓ 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
createOrUpdateConfig
createOrUpdateConfig reconcile configuration for vmanomaly and returns configuration consistent hash
internal/controller/operator/factory/vmanomaly/config.go:20
↓ 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:283
↓ 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:277
↓ 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:289
↓ 2 callers
Function
createOrUpdateRelabelConfigsAssets
createOrUpdateRelabelConfigsAssets builds relabeling configs for vmagent at separate configmap, serialized as yaml
internal/controller/operator/factory/vmagent/vmagent.go:789
↓ 2 callers
Function
createOrUpdateService
createOrUpdateService creates service for vmalert
internal/controller/operator/factory/vmalert/vmalert.go:46
↓ 2 callers
Function
createOrUpdateService
createOrUpdateService creates service for vtsingle
internal/controller/operator/factory/vtsingle/vtsingle.go:283
↓ 2 callers
Function
createOrUpdateService
createOrUpdateService creates service for vlsingle
internal/controller/operator/factory/vlsingle/vlsingle.go:292
↓ 2 callers
Function
createOrUpdateService
(ctx context.Context, rclient client.Client, cr, prevCR *vmv1beta1.VMAgent)
internal/controller/operator/factory/vmagent/vmagent.go:66
↓ 2 callers
Function
createOrUpdateService
(ctx context.Context, rclient client.Client, cr, prevCR *vmv1beta1.VMSingle)
internal/controller/operator/factory/vmsingle/vmsingle.go:329
↓ 2 callers
Function
createOrUpdateStreamAggrConfig
createOrUpdateStreamAggrConfig builds stream aggregation configs for vmagent at separate configmap, serialized as yaml
internal/controller/operator/factory/vmagent/vmagent.go:864
↓ 2 callers
Function
createSteps
(events types.SpecEvents, entries types.ReportEntries)
test/e2e/suite/allure/result.go:138
↓ 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:228
↓ 2 callers
Function
deregisterObjectByCollector
deregisterObject removes from cache given CR object name with namespace for controller
internal/controller/operator/objects_stat.go:86
↓ 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:681
↓ 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
Function
fetchCRDRefURLs
(ctx context.Context, rclient client.Client, refs []vmv1beta1.TargetRef, crdURLCache map[string]string)
internal/controller/operator/factory/vmauth/vmusers_config.go:307
↓ 2 callers
Function
fetchMetricValues
(ctx context.Context, httpClient *http.Client, url, metricName, dimension string)
internal/controller/operator/factory/vmdistributed/util.go:16
↓ 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:840
↓ 2 callers
Function
genURLMaps
generates routing config for given target refs
internal/controller/operator/factory/vmauth/vmusers_config.go:580
↓ 2 callers
Function
genUserCfg
this function mutates user and fills missing fields, such password or username.
internal/controller/operator/factory/vmauth/vmusers_config.go:763
↓ 2 callers
Function
generateNodeScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *parsedObjects, sc *vmv1beta1.VMNodeScrape,
internal/controller/operator/factory/vmagent/nodescrape.go:13
↓ 2 callers
Function
generatePodScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *parsedObjects, sc *vmv1beta1.VMPodScrape, e
internal/controller/operator/factory/vmagent/podscrape.go:13
↓ 2 callers
Function
generateProbeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *parsedObjects, sc *vmv1beta1.VMProbe, ac *b
internal/controller/operator/factory/vmagent/probe.go:49
↓ 2 callers
Function
generateScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, sc *vmv1beta1.VMScrapeConfig, ac *build.AssetsCac
internal/controller/operator/factory/vmagent/scrapeconfig.go:14
↓ 2 callers
Function
generateServiceScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *parsedObjects, sc *vmv1beta1.VMServiceScrape
internal/controller/operator/factory/vmagent/servicescrape.go:13
↓ 2 callers
Function
generateStaticScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, sc *vmv1beta1.VMStaticScrape, ep *vmv1beta1.Targe
internal/controller/operator/factory/vmagent/staticscrape.go:13
↓ 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:102
↓ 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
getTestClient
(predefinedObjects []runtime.Object, fns *interceptor.Funcs)
internal/controller/operator/factory/k8stools/test_helpers.go:105
↓ 2 callers
Function
handleReconcileErr
(ctx context.Context, rclient client.Client, object client.Object, originResult ctrl.Result, err error)
internal/controller/operator/controllers.go:140
↓ 2 callers
Function
hasOwnerReference
(owners []metav1.OwnerReference, owner *metav1.OwnerReference)
internal/controller/operator/factory/vmdistributed/vmauth.go:15
↓ 2 callers
Function
hasRemoteWriteSecrets
(cr *vmv1beta1.VMAgent)
internal/controller/operator/factory/vmagent/vmagent.go:897
↓ 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
Function
jitterForDuration
adds 50% jitter to the given duration
internal/controller/operator/factory/reconcile/status.go:176
↓ 2 callers
Function
makeSpecForVMAuth
(cr *vmv1beta1.VMAuth)
internal/controller/operator/factory/vmauth/vmauth.go:187
↓ 2 callers
Function
mergeAttachMetadataWithScrapeClass
(am *vmv1beta1.AttachMetadata, scrapeClass *vmv1beta1.ScrapeClass)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:834
↓ 2 callers
Function
mergeSpecs
(a, b *T, name string)
internal/controller/operator/factory/vmdistributed/util.go:247
↓ 2 callers
Function
mergeTLSConfigs
(left, right *vmv1beta1.TLSConfig)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:850
↓ 2 callers
Function
mustRouteToJSON
(t *testing.T, r vmv1beta1.SubRoute)
internal/controller/operator/factory/vmalertmanager/config_test.go:24
↓ 2 callers
Function
newCollector
()
internal/controller/operator/objects_stat.go:45
↓ 2 callers
Function
newErrRecreate
(ctx context.Context, r client.Object)
internal/controller/operator/factory/reconcile/reconcile.go:120
↓ 2 callers
Function
newPodSpec
(cr *vmv1.VLAgent)
internal/controller/operator/factory/vlagent/vlagent.go:249
↓ 2 callers
Function
parseNestedRoutes
parseNestedRoutes validates nested routes
api/operator/v1beta1/vmalertmanagerconfig_types.go:254
↓ 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:241
↓ 2 callers
Function
podStatusesToError
(origin error, pod *corev1.Pod)
internal/controller/operator/factory/reconcile/statefulset.go:423
↓ 2 callers
Function
secretFromEvent
(obj interface{})
cmd/config-reloader/k8s_watch.go:117
↓ 2 callers
Method
selectPodScrapes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmagent/objects.go:91
↓ 2 callers
Method
selectProbes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmagent/objects.go:118
↓ 2 callers
Function
selectRules
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAlert)
internal/controller/operator/factory/vmalert/rules.go:95
↓ 2 callers
Method
selectServiceScrapes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmagent/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
↓ 2 callers
Function
setConfigDefaults
(config *rest.Config)
api/client/versioned/typed/operator/v1alpha1/operator_client.go:82
↓ 2 callers
Function
skipLeadingWhitespace
(s string)
internal/controller/operator/factory/vmdistributed/util.go:164
↓ 2 callers
Function
sortStsPodsByID
(src []corev1.Pod)
internal/controller/operator/factory/reconcile/statefulset.go:475
↓ 2 callers
Function
stringMapToMapSlice
(m map[string]string)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:209
↓ 2 callers
Function
updatePVC
(ctx context.Context, rclient client.Client, existingObj, newObj, prevObj *corev1.PersistentVolumeClaim, owner
internal/controller/operator/factory/reconcile/statefulset_pvc_expand.go:200
↓ 2 callers
Function
updateSTSPVC
(ctx context.Context, rclient client.Client, sts *appsv1.StatefulSet, prevVCTs []corev1.PersistentVolumeClaim)
internal/controller/operator/factory/reconcile/statefulset_pvc_expand.go:81
↓ 2 callers
Method
waitForEmptyPQ
(ctx context.Context, rclient client.Client, interval time.Duration, clusterIdx int)
internal/controller/operator/factory/vmdistributed/zone.go:297
↓ 2 callers
Function
waitForPVCReady
(ctx context.Context, rclient client.Client, nsn types.NamespacedName, size resource.Quantity)
internal/controller/operator/factory/reconcile/pvc.go:57
↓ 2 callers
Function
waitForPodReady
(ctx context.Context, rclient client.Client, nsn types.NamespacedName, desiredRevision string, minReadySeconds
internal/controller/operator/factory/reconcile/statefulset.go:396
↓ 2 callers
Function
writeFile
(filename string, content []byte)
test/e2e/suite/allure/misc.go:33
↓ 1 callers
Function
AddAttachment
(name string, mimeType MimeType, content []byte)
test/e2e/suite/allure/api.go:13
↓ 1 callers
Method
AddRefToObj
AddRefToObj adds reference to given object and return it.
api/operator/v1beta1/vmuser_types.go:157
↓ 1 callers
Method
AsListOptions
()
api/operator/v1beta1/vmextra_types.go:483
↓ 1 callers
Method
AsNotifiers
AsNotifiers converts VMAlertmanager into VMAlertNotifierSpec
api/operator/v1beta1/vmalertmanager_types.go:435
↓ 1 callers
Method
AsOwner
AsOwner returns owner references with current object as owner
api/operator/v1alpha1/vmdistributed_types.go:366
↓ 1 callers
Method
AsURL
AsURL implements stub for interface.
api/operator/v1beta1/vmcluster_types.go:877
↓ 1 callers
Method
AsURL
AsURL implements stub for interface. nolint:dupl,lll
api/operator/v1/vtcluster_types.go:748
↓ 1 callers
Method
AutomountServiceAccountToken
AutomountServiceAccountToken implements reloadable interface
api/operator/v1beta1/vmauth_types.go:741
↓ 1 callers
Method
AvailableStorageNodeIDs
AvailableStorageNodeIDs returns ids of the storage nodes for the provided component
api/operator/v1beta1/vmcluster_types.go:718
↓ 1 callers
Method
AvailableStorageNodeIDs
AvailableStorageNodeIDs returns ids of the storage nodes for the provided component
api/operator/v1/vlcluster_types.go:779
↓ 1 callers
Function
ClusterSelectorLabels
ClusterSelectorLabels defines selector labels for given cluster component kind
api/operator/v1beta1/vmextra_types.go:108
↓ 1 callers
Function
ConfigAsMetrics
ConfigAsMetrics exposes major configuration params as prometheus metrics
internal/config/config.go:811
↓ 1 callers
Method
ConfigSecretName
ConfigSecretName returns configuration secret name for alertmanager
api/operator/v1beta1/vmalertmanager_types.go:357
← previous
next →
401–500 of 3,239, ranked by callers