MCPcopy Create free account

hub / github.com/VictoriaMetrics/operator / functions

Functions3,591 in github.com/VictoriaMetrics/operator

↓ 2 callersFunctiongenerateServiceScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, pos *ParsedObjects, sc *vmv1beta1.VMServiceScrape
internal/controller/operator/factory/vmscrapes/servicescrape.go:13
↓ 2 callersFunctiongenerateStaticScrapeConfig
( ctx context.Context, sp *vmv1beta1.CommonScrapeParams, sc *vmv1beta1.VMStaticScrape, ep *vmv1beta1.Targe
internal/controller/operator/factory/vmscrapes/staticscrape.go:13
↓ 2 callersFunctiongetAssetsCache
(ctx context.Context, rclient client.Client, cr *vmv1.VMAnomaly)
internal/controller/operator/factory/vmanomaly/statefulset.go:360
↓ 2 callersFunctiongetFirstValue
(args map[string]string, name string)
api/operator/v1beta1/vmextra_types.go:179
↓ 2 callersFunctiongetLatestPods
(ctx context.Context, rclient client.Client, obj client.Object)
test/e2e/utils_test.go:31
↓ 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:116
↓ 2 callersFunctiongetScrapeDiscoveryRules
getScrapeDiscoveryRules returns the K8s service-discovery rules needed in every watched namespace.
internal/controller/operator/factory/vmagent/rbac.go:17
↓ 2 callersFunctiongetScrapeDiscoveryRules
()
internal/controller/operator/factory/vmsingle/rbac.go:16
↓ 2 callersFunctiongetTestClient
(predefinedObjects []runtime.Object, fns *interceptor.Funcs)
internal/controller/operator/factory/k8stools/test_helpers.go:108
↓ 2 callersFunctionhasOwnerReference
(owners []metav1.OwnerReference, owner *metav1.OwnerReference)
internal/controller/operator/factory/vmdistributed/vmauth.go:16
↓ 2 callersMethodisNodeScrapeUnmanaged
isNodeScrapeUnmanaged checks if scraping agent should managed any VMNodeScrape objects
api/operator/v1beta1/common_scrapeparams.go:731
↓ 2 callersMethodisPodScrapeUnmanaged
isUnmanaged checks if scraping agent should managed any VMPodScrape objects
api/operator/v1beta1/common_scrapeparams.go:749
↓ 2 callersMethodisProbeUnmanaged
isProbeUnmanaged checks if scraping agent should managed any VMProbe objects
api/operator/v1beta1/common_scrapeparams.go:758
↓ 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 callersMethodisScrapeConfigUnmanaged
isScrapeConfigUnmanaged checks if scraping agent should managed any VMScrapeConfig objects
api/operator/v1beta1/common_scrapeparams.go:776
↓ 2 callersMethodisServiceScrapeUnmanaged
isServiceScrapeUnmanaged checks if scraping agent should managed any VMServiceScrape objects
api/operator/v1beta1/common_scrapeparams.go:740
↓ 2 callersMethodisStaticScrapeUnmanaged
isStaticScrapeUnmanaged checks if scraping agent should managed any VMStaticScrape objects
api/operator/v1beta1/common_scrapeparams.go:767
↓ 2 callersMethodisUnmanaged
isUnmanaged checks if object should managed any config objects
api/operator/v1beta1/common_scrapeparams.go:717
↓ 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:190
↓ 2 callersFunctionmaybeDecompress
maybeDecompress returns data decompressed if gzip magic is detected, otherwise as-is.
cmd/config-reloader/file_watch.go:332
↓ 2 callersFunctionmergeAttachMetadataWithScrapeClass
(am *vmv1beta1.AttachMetadata, scrapeClass *vmv1beta1.ScrapeClass)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:696
↓ 2 callersFunctionmergeMetaInternal
(existingObj, newObj client.Object, prevMeta *metav1.ObjectMeta, owner *metav1.OwnerReference, shouldRemoveFin
internal/controller/operator/factory/reconcile/reconcile.go:125
↓ 2 callersFunctionmergeTLSConfigs
(left, right *vmv1beta1.TLSConfig)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:712
↓ 2 callersFunctionmustRouteToJSON
(t *testing.T, r vmv1beta1.SubRoute)
internal/controller/operator/factory/vmalertmanager/config_test.go:24
↓ 2 callersFunctionnewErrRecreate
(ctx context.Context, r client.Object)
internal/controller/operator/factory/reconcile/reconcile.go:159
↓ 2 callersFunctionnewPodSpec
(cr *vmv1.VLAgent)
internal/controller/operator/factory/vlagent/vlagent.go:261
↓ 2 callersFunctionnewPodSpec
(ctx context.Context, cr *vmv1beta1.VMSingle, extraConfigSecretCount int)
internal/controller/operator/factory/vmsingle/vmsingle.go:181
↓ 2 callersFunctionparseNestedRoutes
parseNestedRoutes validates nested routes
api/operator/v1beta1/vmalertmanagerconfig_types.go:350
↓ 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:257
↓ 2 callersFunctionpodStatusesToError
(origin error, pod *corev1.Pod)
internal/controller/operator/factory/reconcile/statefulset.go:439
↓ 2 callersFunctionsecretFromEvent
(obj interface{})
cmd/config-reloader/k8s_watch.go:123
↓ 2 callersMethodselectPodScrapes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmscrapes/objects.go:91
↓ 2 callersMethodselectProbes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmscrapes/objects.go:118
↓ 2 callersFunctionselectRules
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAlert)
internal/controller/operator/factory/vmalert/rules.go:99
↓ 2 callersMethodselectServiceScrapes
(ctx context.Context, rclient client.Client, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmscrapes/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:178
↓ 2 callersFunctionsortStsPodsByID
(src []corev1.Pod)
internal/controller/operator/factory/reconcile/statefulset.go:491
↓ 2 callersFunctionstorageNodeSRVAddr
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 callersFunctionstringMapToMapSlice
(m map[string]string)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:84
↓ 2 callersMethodsync
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 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 callersMethodvalidateArbitraryFSAccess
()
api/operator/v1beta1/vmalertmanagerconfig_types.go:1761
↓ 2 callersFunctionvmBackendTargetRef
(backends []vmBackend, kind string, paths []string, owner *metav1.OwnerReference, excludeIds ...int)
internal/controller/operator/factory/vmdistributed/vmauth.go:26
↓ 2 callersMethodwaitForEmptyPQ
(ctx context.Context, rclient client.Client, interval time.Duration, clusterIdx int)
internal/controller/operator/factory/vmdistributed/zone.go:427
↓ 2 callersFunctionwaitForPVCReady
(ctx context.Context, rclient client.Client, nsn types.NamespacedName, size resource.Quantity)
internal/controller/operator/factory/reconcile/pvc.go:58
↓ 2 callersFunctionwaitForPodReady
(ctx context.Context, rclient client.Client, nsn types.NamespacedName, desiredRevision string, minReadySeconds
internal/controller/operator/factory/reconcile/statefulset.go:412
↓ 2 callersFunctionwarnDistributedOpenShiftSC
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 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 callersFunctionAlertmanagerConfig
AlertmanagerConfig creates VMAlertmanagerConfig from prometheus alertmanagerConfig
internal/controller/operator/factory/converter/v1alpha1/apis.go:103
↓ 1 callersMethodAsListOptions
()
api/operator/v1beta1/vmextra_types.go:544
↓ 1 callersMethodAsNotifiers
AsNotifiers converts VMAlertmanager into VMAlertNotifierSpec
api/operator/v1beta1/vmalertmanager_types.go:442
↓ 1 callersMethodAsOwner
AsOwner returns owner references with current object as owner
api/operator/v1beta1/vmalert_types.go:351
↓ 1 callersMethodAsOwner
AsOwner returns owner references with current object as owner
api/operator/v1beta1/vmsingle_types.go:270
↓ 1 callersMethodAsOwner
AsOwner returns owner references with current object as owner
api/operator/v1/vmanomaly_types.go:299
↓ 1 callersMethodAsURL
AsURL implements stub for interface.
api/operator/v1beta1/vmcluster_types.go:1007
↓ 1 callersMethodAsURL
(isExtra bool)
api/operator/v1beta1/vmsingle_types.go:379
↓ 1 callersMethodAsURL
AsURL implements stub for interface. nolint:dupl,lll
api/operator/v1/vtcluster_types.go:771
↓ 1 callersMethodAutomountServiceAccountToken
AutomountServiceAccountToken implements reloadable interface
api/operator/v1beta1/vmauth_types.go:800
↓ 1 callersMethodAvailableStorageNodeIDs
AvailableStorageNodeIDs returns ids of the storage nodes for the provided component
api/operator/v1beta1/vmcluster_types.go:851
↓ 1 callersMethodAvailableStorageNodeIDs
AvailableStorageNodeIDs returns ids of the storage nodes for the provided component
api/operator/v1/vlcluster_types.go:805
↓ 1 callersFunctionClusterSelectorLabels
ClusterSelectorLabels defines selector labels for given cluster component kind
api/operator/v1beta1/vmextra_types.go:143
↓ 1 callersFunctionConfigAsMetrics
ConfigAsMetrics exposes major configuration params as prometheus metrics
internal/config/config.go:996
↓ 1 callersFunctionConsistentlyShouldNotHaveFinalizer
(namespace string, listProtos ...client.ObjectList)
test/e2e/watchnamespace/utils_test.go:71
↓ 1 callersFunctionConvertProxyConfig
(prom *promv1.ProxyConfig)
internal/controller/operator/factory/converter/apis.go:551
↓ 1 callersMethodCreate
(ctx context.Context, obj client.Object, opts ...client.CreateOption)
internal/manager/client.go:24
↓ 1 callersFunctionCreateOrUpdateConfig
CreateOrUpdateConfig builds configuration for VMAnomaly
internal/controller/operator/factory/vmanomaly/config.go:18
↓ 1 callersFunctionCreateOrUpdateScrapeConfig
CreateOrUpdateScrapeConfig builds scrape configuration for VMAgent
internal/controller/operator/factory/vmagent/vmagent.go:1341
↓ 1 callersFunctionCreateOrUpdateScrapeConfig
CreateOrUpdateScrapeConfig builds scrape configuration for VMSingle
internal/controller/operator/factory/vmsingle/vmsingle.go:751
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VLogs.
api/operator/v1beta1/zz_generated.deepcopy.go:4455
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VLogsList.
api/operator/v1beta1/zz_generated.deepcopy.go:4487
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAgentList.
api/operator/v1beta1/zz_generated.deepcopy.go:4609
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAlertList.
api/operator/v1beta1/zz_generated.deepcopy.go:4976
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAlertSpec.
api/operator/v1beta1/zz_generated.deepcopy.go:5174
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAlertmanagerConfigList.
api/operator/v1beta1/zz_generated.deepcopy.go:5273
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAlertmanagerList.
api/operator/v1beta1/zz_generated.deepcopy.go:5409
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAuthList.
api/operator/v1beta1/zz_generated.deepcopy.go:5653
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMClusterList.
api/operator/v1beta1/zz_generated.deepcopy.go:6066
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMClusterSpec.
api/operator/v1beta1/zz_generated.deepcopy.go:6140
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMNodeScrape.
api/operator/v1beta1/zz_generated.deepcopy.go:6246
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMNodeScrapeList.
api/operator/v1beta1/zz_generated.deepcopy.go:6278
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMPodScrape.
api/operator/v1beta1/zz_generated.deepcopy.go:6333
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMPodScrapeList.
api/operator/v1beta1/zz_generated.deepcopy.go:6365
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMProbe.
api/operator/v1beta1/zz_generated.deepcopy.go:6427
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMProbeList.
api/operator/v1beta1/zz_generated.deepcopy.go:6459
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMRule.
api/operator/v1beta1/zz_generated.deepcopy.go:6677
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMRuleList.
api/operator/v1beta1/zz_generated.deepcopy.go:6709
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMScrapeConfig.
api/operator/v1beta1/zz_generated.deepcopy.go:6774
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMScrapeConfigList.
api/operator/v1beta1/zz_generated.deepcopy.go:6806
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMServiceScrape.
api/operator/v1beta1/zz_generated.deepcopy.go:7144
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMServiceScrapeList.
api/operator/v1beta1/zz_generated.deepcopy.go:7176
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMSingleList.
api/operator/v1beta1/zz_generated.deepcopy.go:7275
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMStaticScrape.
api/operator/v1beta1/zz_generated.deepcopy.go:7412
↓ 1 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMStaticScrapeList.
api/operator/v1beta1/zz_generated.deepcopy.go:7444
← previousnext →501–600 of 3,591, ranked by callers