Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/VictoriaMetrics/operator
/ functions
Functions
3,591 in github.com/VictoriaMetrics/operator
⨍
Functions
3,591
◇
Types & classes
1,008
↓ 1 callers
Function
ensureVMAuthRoleExist
(ctx context.Context, rclient client.Client, cr, prevCR *vmv1beta1.VMAuth)
internal/controller/operator/factory/vmauth/rbac.go:26
↓ 1 callers
Function
entries
(es []entry)
test/e2e/upgrade/upgrade_test.go:471
↓ 1 callers
Method
externalLabelName
()
api/operator/v1beta1/common_scrapeparams.go:669
↓ 1 callers
Function
filterSTSPods
(pods []corev1.Pod, revision string, minReadySeconds int32, recreate bool)
internal/controller/operator/factory/reconcile/statefulset.go:524
↓ 1 callers
Function
filterUnsupportedRelabelCfg
(ctx context.Context, relabelCfgs []*vmv1beta1.RelabelConfig)
internal/controller/operator/factory/converter/apis.go:513
↓ 1 callers
Function
findByEventEnd
(events types.SpecEvents, startEvent types.SpecEvent)
test/e2e/suite/allure/result.go:192
↓ 1 callers
Function
findClosingQuote
(s string)
internal/controller/operator/factory/vmdistributed/util.go:233
↓ 1 callers
Function
flagsAsMetrics
(registry metrics.RegistererGatherer, flagSet *flag.FlagSet)
internal/manager/manager.go:637
↓ 1 callers
Function
formatSecretSelectorKeyPath
(secretKey *corev1.SecretKeySelector)
internal/controller/operator/factory/vlagent/vlagent.go:772
↓ 1 callers
Function
genVMAgentSpec
()
test/e2e/vmdistributed_test.go:66
↓ 1 callers
Function
genVMClusterSpec
(opts ...func(*vmv1beta1.VMClusterSpec))
test/e2e/vmdistributed_test.go:24
↓ 1 callers
Function
genVMInsertSpec
(cr *vmv1beta1.VMCluster)
internal/controller/operator/factory/vmcluster/vmcluster.go:766
↓ 1 callers
Function
genVMSelectSpec
(cr *vmv1beta1.VMCluster)
internal/controller/operator/factory/vmcluster/vmcluster.go:519
↓ 1 callers
Method
generateConfig
generateVMAuthConfig create VMAuth cfg for given Users.
internal/controller/operator/factory/vmauth/vmusers_config.go:403
↓ 1 callers
Function
generateHTTPSDOptions
(config vmv1beta1.HTTPSDOptions, namespace string, ac *build.AssetsCache)
internal/controller/operator/factory/vmscrapes/scrapeconfig.go:1045
↓ 1 callers
Function
getApplications
(objs ...client.Object)
test/e2e/upgrade/utils.go:335
↓ 1 callers
Function
getAsURLObject
(ctx context.Context, rclient client.Client, objT objectWithURL, isExtra bool)
internal/controller/operator/factory/vmauth/vmusers_config.go:179
↓ 1 callers
Function
getClientCacheOptions
(disabledCacheObjects string)
internal/manager/manager.go:401
↓ 1 callers
Function
getClusterWideRules
(cr *vmv1beta1.VMAgent)
internal/controller/operator/factory/vmagent/rbac.go:56
↓ 1 callers
Function
getClusterWideRules
(cr *vmv1beta1.VMSingle)
internal/controller/operator/factory/vmsingle/rbac.go:49
↓ 1 callers
Function
getDeploymentCondition
(status appsv1.DeploymentStatus, condType appsv1.DeploymentConditionType)
internal/controller/operator/factory/reconcile/deploy.go:143
↓ 1 callers
Function
getFieldsDescriptions
(currStruct *ast.StructType)
internal/config/print.go:132
↓ 1 callers
Function
getLatestStsState
this change is needed to properly handle revision version fields object was processed by controller-manager if ObservedGeneration matches current gene
internal/controller/operator/factory/reconcile/statefulset.go:205
↓ 1 callers
Function
getLocalIPs
GetLocalIPs returns a list of local IP addresses
test/e2e/suite/suite.go:240
↓ 1 callers
Function
getMetricsAddrs
(ctx context.Context, rclient client.Client, vmAgent *vmv1beta1.VMAgent)
internal/controller/operator/factory/vmdistributed/zone.go:378
↓ 1 callers
Function
getMetricsServerMTLSOpts
()
internal/manager/manager.go:607
↓ 1 callers
Function
getObject
(ctx context.Context, obj client.Object)
test/e2e/prometheus_converter_test.go:293
↓ 1 callers
Function
getRoleRelabelings
(role string)
internal/controller/operator/factory/vmscrapes/probe.go:13
↓ 1 callers
Function
getRolloutDiff
(ctx context.Context, k8sClient client.Client, expectedPodSpec *corev1.PodSpec, o client.Object)
test/e2e/upgrade/utils.go:315
↓ 1 callers
Function
getSecretContentForAlertmanager
(ctx context.Context, rclient client.Client, secretName, ns string)
internal/controller/operator/factory/vmalertmanager/statefulset.go:573
↓ 1 callers
Function
getShard
(cr *vmv1.VMAnomaly, appTpl *appsv1.StatefulSet, num int32)
internal/controller/operator/factory/vmanomaly/statefulset.go:348
↓ 1 callers
Function
getSingleNamespaceRules
getSingleNamespaceRules returns rules for the Role that lives in cr's own namespace. It includes a scoped secrets rule for the config-reloader plus th
internal/controller/operator/factory/vmagent/rbac.go:39
↓ 1 callers
Function
getSingleNamespaceRules
(cr *vmv1beta1.VMSingle)
internal/controller/operator/factory/vmsingle/rbac.go:36
↓ 1 callers
Function
getSnapshots
(ctx context.Context, k8sClient client.Client, objs ...client.Object)
test/e2e/upgrade/utils.go:283
↓ 1 callers
Function
getTestStatus
(report ginkgo.SpecReport)
test/e2e/suite/allure/status.go:28
↓ 1 callers
Function
getTimestampMs
()
test/e2e/suite/allure/misc.go:25
↓ 1 callers
Function
getVersion
(defaultVersion string)
internal/config/config.go:25
↓ 1 callers
Function
groupNamesFromCM
groupNamesFromCM decompresses and unmarshals the rules.yaml BinaryData entry, returning the contained group names for easy assertion.
internal/controller/operator/factory/vmalert/rules_test.go:25
↓ 1 callers
Method
has
(id string)
internal/controller/operator/factory/vmdistributed/zone.go:547
↓ 1 callers
Function
honorLabels
honorLabels determines the value of honor_labels. if overrideHonorLabels is true and user tries to set the value to true, we want to set honor_labels
internal/controller/operator/factory/vmscrapes/vmscrapes.go:103
↓ 1 callers
Function
honorTimestamps
honorTimestamps adds option to enforce honor_timestamps option in scrape_config. We want to disable honoring timestamps when user specified it or when
internal/controller/operator/factory/vmscrapes/vmscrapes.go:114
↓ 1 callers
Method
ids
()
internal/controller/operator/factory/vmdistributed/zone.go:578
↓ 1 callers
Method
init
(class string)
internal/controller/operator/factory/vmanomaly/config/schedulers.go:47
↓ 1 callers
Method
init
(class string)
internal/controller/operator/factory/vmanomaly/config/models.go:65
↓ 1 callers
Function
initControllers
(mgr ctrl.Manager, l logr.Logger, baseClient *kubernetes.Clientset, bs *config.BaseOperatorConf)
internal/manager/manager.go:524
↓ 1 callers
Function
injectAuthSettings
(secret *corev1.Secret, vmuser *vmv1beta1.VMUser)
internal/controller/operator/factory/vmauth/vmusers_config.go:266
↓ 1 callers
Function
injectBackendAuthHeader
(user *vmv1beta1.VMUser, ac *build.AssetsCache)
internal/controller/operator/factory/vmauth/vmusers_config.go:246
↓ 1 callers
Function
isConflict
(err error)
internal/controller/operator/factory/reconcile/reconcile.go:184
↓ 1 callers
Function
isLocalHost
(host string)
test/e2e/suite/suite.go:225
↓ 1 callers
Function
isNamespaceSelectorMatches
(ctx context.Context, rclient client.Client, sourceCRD, targetCRD client.Object, selector *metav1.LabelSelecto
internal/controller/operator/controllers.go:205
↓ 1 callers
Function
isOwnedBySTS
(pod *corev1.Pod)
internal/controller/operator/factory/reconcile/statefulset.go:515
↓ 1 callers
Function
isParsingError
(err error)
internal/controller/operator/controllers.go:104
↓ 1 callers
Function
isRecreate
(err error)
internal/controller/operator/factory/reconcile/reconcile.go:150
↓ 1 callers
Function
isStorageClassExpandable
isStorageClassExpandable check is it possible to update size of given pvc
internal/controller/operator/factory/reconcile/statefulset_pvc_expand.go:215
↓ 1 callers
Function
isSubset
(set map[string]string, subset map[string]string)
internal/controller/operator/factory/finalize/orphaned.go:148
↓ 1 callers
Method
isUnmanaged
isUnmanaged checks if provided Selectors are not defined and there is no need to perform any query requests for Kubernetes objects
internal/controller/operator/factory/k8stools/selectors.go:31
↓ 1 callers
Method
load
(ctx context.Context)
cmd/config-reloader/main.go:322
↓ 1 callers
Function
main
()
hack/compare_versions.py:12
↓ 1 callers
Function
makePodSpec
(r *vmv1.VTSingle)
internal/controller/operator/factory/vtsingle/vtsingle.go:174
↓ 1 callers
Function
makePodSpec
(r *vmv1.VLSingle)
internal/controller/operator/factory/vlsingle/vlsingle.go:174
↓ 1 callers
Function
makePodSpecForVMInsert
(cr *vmv1beta1.VMCluster)
internal/controller/operator/factory/vmcluster/vmcluster.go:804
↓ 1 callers
Function
makePodSpecForVMSelect
(cr *vmv1beta1.VMCluster)
internal/controller/operator/factory/vmcluster/vmcluster.go:558
↓ 1 callers
Function
makePodSpecForVMStorage
(ctx context.Context, cr *vmv1beta1.VMCluster)
internal/controller/operator/factory/vmcluster/vmcluster.go:1017
↓ 1 callers
Function
makePvc
(cr *vmv1beta1.VMSingle)
internal/controller/operator/factory/vmsingle/vmsingle.go:58
↓ 1 callers
Function
makeRulesConfigMaps
makeRulesConfigMaps packs rule groups into gzip-compressed ConfigMap buckets using build.PackItems with 50% headroom. Each bucket is stored as one "ru
internal/controller/operator/factory/vmalert/rules.go:192
↓ 1 callers
Function
makeStatefulSetSpec
(cr *vmv1beta1.VMAlertmanager)
internal/controller/operator/factory/vmalertmanager/statefulset.go:158
↓ 1 callers
Method
marshal
()
internal/controller/operator/factory/vmanomaly/config/config.go:389
↓ 1 callers
Function
marshalValues
(vs map[string]T)
internal/controller/operator/factory/vmanomaly/config/config.go:378
↓ 1 callers
Function
mergeAuthorizationWithScrapeClass
(authz *vmv1beta1.Authorization, scrapeClass *vmv1beta1.ScrapeClass)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:628
↓ 1 callers
Function
mergeBasicAuthWithScrapeClass
(ba *vmv1beta1.BasicAuth, scrapeClass *vmv1beta1.ScrapeClass)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:647
↓ 1 callers
Function
mergeOAuth2WithScrapeClass
(oauth2 *vmv1beta1.OAuth2, scrapeClass *vmv1beta1.ScrapeClass)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:664
↓ 1 callers
Function
modifyPVC
(ctx context.Context, rclient client.Client, existingObj, newObj, prevObj *corev1.PersistentVolumeClaim, owner
internal/controller/operator/factory/reconcile/statefulset_pvc_expand.go:139
↓ 1 callers
Function
mustAddRestClientMetrics
(r metrics.RegistererGatherer)
internal/manager/manager.go:466
↓ 1 callers
Function
mustGetLoggerEncodingOpts
()
internal/manager/manager.go:565
↓ 1 callers
Function
newAttachment
(name string, mimeType MimeType, content []byte)
test/e2e/suite/allure/attachment.go:66
↓ 1 callers
Function
newClusterWithURL
(component string)
internal/controller/operator/factory/vmauth/vmusers_config.go:374
↓ 1 callers
Function
newConfigWatcher
(ctx context.Context)
cmd/config-reloader/main.go:338
↓ 1 callers
Function
newDeploy
newDeploy returns a busybox pod with the same name/namespace as the cr
internal/controller/operator/factory/vmalert/vmalert.go:175
↓ 1 callers
Function
newDeploy
(ctx context.Context, cr *vmv1beta1.VMSingle, extraConfigSecretCount int)
internal/controller/operator/factory/vmsingle/vmsingle.go:151
↓ 1 callers
Function
newDeployForVMAuth
(cr *vmv1beta1.VMAuth)
internal/controller/operator/factory/vmauth/vmauth.go:155
↓ 1 callers
Function
newDeployment
(r *vmv1.VTSingle)
internal/controller/operator/factory/vtsingle/vtsingle.go:144
↓ 1 callers
Function
newDeployment
(r *vmv1.VLSingle)
internal/controller/operator/factory/vlsingle/vlsingle.go:144
↓ 1 callers
Function
newFakeVLAgents
(fake *FakeOperatorV1, namespace string)
api/client/versioned/typed/operator/v1/fake/fake_vlagent.go:32
↓ 1 callers
Function
newFakeVLClusters
(fake *FakeOperatorV1, namespace string)
api/client/versioned/typed/operator/v1/fake/fake_vlcluster.go:32
↓ 1 callers
Function
newFakeVLSingles
(fake *FakeOperatorV1, namespace string)
api/client/versioned/typed/operator/v1/fake/fake_vlsingle.go:32
↓ 1 callers
Function
newFakeVLogs
(fake *FakeOperatorV1beta1, namespace string)
api/client/versioned/typed/operator/v1beta1/fake/fake_vlogs.go:32
↓ 1 callers
Function
newFakeVMAgents
(fake *FakeOperatorV1beta1, namespace string)
api/client/versioned/typed/operator/v1beta1/fake/fake_vmagent.go:32
↓ 1 callers
Function
newFakeVMAlertmanagerConfigs
(fake *FakeOperatorV1beta1, namespace string)
api/client/versioned/typed/operator/v1beta1/fake/fake_vmalertmanagerconfig.go:32
↓ 1 callers
Function
newFakeVMAlertmanagers
(fake *FakeOperatorV1beta1, namespace string)
api/client/versioned/typed/operator/v1beta1/fake/fake_vmalertmanager.go:32
↓ 1 callers
Function
newFakeVMAlerts
(fake *FakeOperatorV1beta1, namespace string)
api/client/versioned/typed/operator/v1beta1/fake/fake_vmalert.go:32
↓ 1 callers
Function
newFakeVMAnomalies
(fake *FakeOperatorV1, namespace string)
api/client/versioned/typed/operator/v1/fake/fake_vmanomaly.go:32
↓ 1 callers
Function
newFakeVMAuths
(fake *FakeOperatorV1beta1, namespace string)
api/client/versioned/typed/operator/v1beta1/fake/fake_vmauth.go:32
↓ 1 callers
Function
newFakeVMClusters
(fake *FakeOperatorV1beta1, namespace string)
api/client/versioned/typed/operator/v1beta1/fake/fake_vmcluster.go:32
↓ 1 callers
Function
newFakeVMDistributed
(fake *FakeOperatorV1alpha1, namespace string)
api/client/versioned/typed/operator/v1alpha1/fake/fake_vmdistributed.go:32
↓ 1 callers
Function
newFakeVMNodeScrapes
(fake *FakeOperatorV1beta1, namespace string)
api/client/versioned/typed/operator/v1beta1/fake/fake_vmnodescrape.go:32
↓ 1 callers
Function
newFakeVMPodScrapes
(fake *FakeOperatorV1beta1, namespace string)
api/client/versioned/typed/operator/v1beta1/fake/fake_vmpodscrape.go:32
↓ 1 callers
Function
newFakeVMProbes
(fake *FakeOperatorV1beta1, namespace string)
api/client/versioned/typed/operator/v1beta1/fake/fake_vmprobe.go:32
↓ 1 callers
Function
newFakeVMRules
(fake *FakeOperatorV1beta1, namespace string)
api/client/versioned/typed/operator/v1beta1/fake/fake_vmrule.go:32
↓ 1 callers
Function
newFakeVMScrapeConfigs
(fake *FakeOperatorV1beta1, namespace string)
api/client/versioned/typed/operator/v1beta1/fake/fake_vmscrapeconfig.go:32
↓ 1 callers
Function
newFakeVMServiceScrapes
(fake *FakeOperatorV1beta1, namespace string)
api/client/versioned/typed/operator/v1beta1/fake/fake_vmservicescrape.go:32
← previous
next →
1,301–1,400 of 3,591, ranked by callers