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
↓ 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:360
↓ 2 callers
Function
getFirstValue
(args map[string]string, name string)
api/operator/v1beta1/vmextra_types.go:179
↓ 2 callers
Function
getLatestPods
(ctx context.Context, rclient client.Client, obj client.Object)
test/e2e/utils_test.go:31
↓ 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:116
↓ 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:108
↓ 2 callers
Function
hasOwnerReference
(owners []metav1.OwnerReference, owner *metav1.OwnerReference)
internal/controller/operator/factory/vmdistributed/vmauth.go:16
↓ 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
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
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:190
↓ 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:125
↓ 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:159
↓ 2 callers
Function
newPodSpec
(cr *vmv1.VLAgent)
internal/controller/operator/factory/vlagent/vlagent.go:261
↓ 2 callers
Function
newPodSpec
(ctx context.Context, cr *vmv1beta1.VMSingle, extraConfigSecretCount int)
internal/controller/operator/factory/vmsingle/vmsingle.go:181
↓ 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
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
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAlert)
internal/controller/operator/factory/vmalert/rules.go:99
↓ 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
↓ 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:178
↓ 2 callers
Function
sortStsPodsByID
(src []corev1.Pod)
internal/controller/operator/factory/reconcile/statefulset.go:491
↓ 2 callers
Function
storageNodeSRVAddr
storageNodeSRVAddr builds the address used for DNS SRV-based vmstorage discovery. It mirrors the format used by PodDNSAddress but targets the headless
internal/controller/operator/factory/vmcluster/vmcluster.go:1753
↓ 2 callers
Function
stringMapToMapSlice
(m map[string]string)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:84
↓ 2 callers
Method
sync
sync atomically replaces p.target with the decompressed contents of p.src. All new content is first written to a sibling temp directory; the target is
cmd/config-reloader/file_watch.go:127
↓ 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
validateArbitraryFSAccess
()
api/operator/v1beta1/vmalertmanagerconfig_types.go:1761
↓ 2 callers
Function
vmBackendTargetRef
(backends []vmBackend, kind string, paths []string, owner *metav1.OwnerReference, excludeIds ...int)
internal/controller/operator/factory/vmdistributed/vmauth.go:26
↓ 2 callers
Method
waitForEmptyPQ
(ctx context.Context, rclient client.Client, interval time.Duration, clusterIdx int)
internal/controller/operator/factory/vmdistributed/zone.go:427
↓ 2 callers
Function
waitForPVCReady
(ctx context.Context, rclient client.Client, nsn types.NamespacedName, size resource.Quantity)
internal/controller/operator/factory/reconcile/pvc.go:58
↓ 2 callers
Function
waitForPodReady
(ctx context.Context, rclient client.Client, nsn types.NamespacedName, desiredRevision string, minReadySeconds
internal/controller/operator/factory/reconcile/statefulset.go:412
↓ 2 callers
Function
warnDistributedOpenShiftSC
warnDistributedOpenShiftSC collects OpenShift security context warnings for all sub-components of a VMDistributed spec: VMAuth, ZoneCommon, and each i
internal/webhook/operator/v1alpha1/vmdistributed_webhook.go:44
↓ 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
Function
AlertmanagerConfig
AlertmanagerConfig creates VMAlertmanagerConfig from prometheus alertmanagerConfig
internal/controller/operator/factory/converter/v1alpha1/apis.go:103
↓ 1 callers
Method
AsListOptions
()
api/operator/v1beta1/vmextra_types.go:544
↓ 1 callers
Method
AsNotifiers
AsNotifiers converts VMAlertmanager into VMAlertNotifierSpec
api/operator/v1beta1/vmalertmanager_types.go:442
↓ 1 callers
Method
AsOwner
AsOwner returns owner references with current object as owner
api/operator/v1beta1/vmalert_types.go:351
↓ 1 callers
Method
AsOwner
AsOwner returns owner references with current object as owner
api/operator/v1beta1/vmsingle_types.go:270
↓ 1 callers
Method
AsOwner
AsOwner returns owner references with current object as owner
api/operator/v1/vmanomaly_types.go:299
↓ 1 callers
Method
AsURL
AsURL implements stub for interface.
api/operator/v1beta1/vmcluster_types.go:1007
↓ 1 callers
Method
AsURL
(isExtra bool)
api/operator/v1beta1/vmsingle_types.go:379
↓ 1 callers
Method
AsURL
AsURL implements stub for interface. nolint:dupl,lll
api/operator/v1/vtcluster_types.go:771
↓ 1 callers
Method
AutomountServiceAccountToken
AutomountServiceAccountToken implements reloadable interface
api/operator/v1beta1/vmauth_types.go:800
↓ 1 callers
Method
AvailableStorageNodeIDs
AvailableStorageNodeIDs returns ids of the storage nodes for the provided component
api/operator/v1beta1/vmcluster_types.go:851
↓ 1 callers
Method
AvailableStorageNodeIDs
AvailableStorageNodeIDs returns ids of the storage nodes for the provided component
api/operator/v1/vlcluster_types.go:805
↓ 1 callers
Function
ClusterSelectorLabels
ClusterSelectorLabels defines selector labels for given cluster component kind
api/operator/v1beta1/vmextra_types.go:143
↓ 1 callers
Function
ConfigAsMetrics
ConfigAsMetrics exposes major configuration params as prometheus metrics
internal/config/config.go:996
↓ 1 callers
Function
ConsistentlyShouldNotHaveFinalizer
(namespace string, listProtos ...client.ObjectList)
test/e2e/watchnamespace/utils_test.go:71
↓ 1 callers
Function
ConvertProxyConfig
(prom *promv1.ProxyConfig)
internal/controller/operator/factory/converter/apis.go:551
↓ 1 callers
Method
Create
(ctx context.Context, obj client.Object, opts ...client.CreateOption)
internal/manager/client.go:24
↓ 1 callers
Function
CreateOrUpdateConfig
CreateOrUpdateConfig builds configuration for VMAnomaly
internal/controller/operator/factory/vmanomaly/config.go:18
↓ 1 callers
Function
CreateOrUpdateScrapeConfig
CreateOrUpdateScrapeConfig builds scrape configuration for VMAgent
internal/controller/operator/factory/vmagent/vmagent.go:1341
↓ 1 callers
Function
CreateOrUpdateScrapeConfig
CreateOrUpdateScrapeConfig builds scrape configuration for VMSingle
internal/controller/operator/factory/vmsingle/vmsingle.go:751
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VLogs.
api/operator/v1beta1/zz_generated.deepcopy.go:4455
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VLogsList.
api/operator/v1beta1/zz_generated.deepcopy.go:4487
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAgentList.
api/operator/v1beta1/zz_generated.deepcopy.go:4609
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAlertList.
api/operator/v1beta1/zz_generated.deepcopy.go:4976
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAlertSpec.
api/operator/v1beta1/zz_generated.deepcopy.go:5174
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAlertmanagerConfigList.
api/operator/v1beta1/zz_generated.deepcopy.go:5273
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAlertmanagerList.
api/operator/v1beta1/zz_generated.deepcopy.go:5409
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAuthList.
api/operator/v1beta1/zz_generated.deepcopy.go:5653
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMClusterList.
api/operator/v1beta1/zz_generated.deepcopy.go:6066
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMClusterSpec.
api/operator/v1beta1/zz_generated.deepcopy.go:6140
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMNodeScrape.
api/operator/v1beta1/zz_generated.deepcopy.go:6246
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMNodeScrapeList.
api/operator/v1beta1/zz_generated.deepcopy.go:6278
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMPodScrape.
api/operator/v1beta1/zz_generated.deepcopy.go:6333
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMPodScrapeList.
api/operator/v1beta1/zz_generated.deepcopy.go:6365
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMProbe.
api/operator/v1beta1/zz_generated.deepcopy.go:6427
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMProbeList.
api/operator/v1beta1/zz_generated.deepcopy.go:6459
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMRule.
api/operator/v1beta1/zz_generated.deepcopy.go:6677
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMRuleList.
api/operator/v1beta1/zz_generated.deepcopy.go:6709
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMScrapeConfig.
api/operator/v1beta1/zz_generated.deepcopy.go:6774
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMScrapeConfigList.
api/operator/v1beta1/zz_generated.deepcopy.go:6806
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMServiceScrape.
api/operator/v1beta1/zz_generated.deepcopy.go:7144
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMServiceScrapeList.
api/operator/v1beta1/zz_generated.deepcopy.go:7176
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMSingleList.
api/operator/v1beta1/zz_generated.deepcopy.go:7275
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMStaticScrape.
api/operator/v1beta1/zz_generated.deepcopy.go:7412
↓ 1 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMStaticScrapeList.
api/operator/v1beta1/zz_generated.deepcopy.go:7444
← previous
next →
501–600 of 3,591, ranked by callers