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
↓ 9 callers
Function
UseProxyProtocol
UseProxyProtocol is a helper for build.probeCRD interface implementations
api/operator/v1beta1/vmextra_types.go:190
↓ 9 callers
Function
generateRelabelConfig
(rc *vmv1beta1.RelabelConfig)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:172
↓ 9 callers
Function
removeOrphaned
removeOrphaned removes orphaned resources
internal/controller/operator/factory/finalize/orphaned.go:119
↓ 8 callers
Function
CreateOrUpdate
CreateOrUpdate reconciled cluster object with order first we check status of vmStorage and waiting for its readiness then vmSelect and wait for it rea
internal/controller/operator/factory/vmcluster/vmcluster.go:37
↓ 8 callers
Method
IntoSTSVolume
IntoSTSVolume converts storageSpec into proper volume for statefulsetSpec by default, it adds emptyDir volume.
api/operator/v1beta1/vmextra_types.go:239
↓ 8 callers
Method
IsUnmanaged
IsUnmanaged checks if object should managed any config objects
api/operator/v1beta1/vmauth_types.go:764
↓ 8 callers
Function
ListObjectsByNamespace
ListObjectsByNamespace performs object list for given namespaces
internal/controller/operator/factory/k8stools/client_utils.go:109
↓ 8 callers
Method
PrefixedName
()
api/operator/v1beta1/vmalertmanager_types.go:373
↓ 8 callers
Method
PrefixedName
()
api/operator/v1beta1/vmsingle_types.go:332
↓ 8 callers
Function
handleReconcileErr
(ctx context.Context, rclient client.Client, object client.Object, originResult ctrl.Result, err error)
internal/controller/operator/controllers.go:143
↓ 7 callers
Method
AsOwner
()
internal/controller/operator/factory/finalize/common.go:18
↓ 7 callers
Method
AvailableStorageNodeIDs
AvailableStorageNodeIDs returns ids of the storage nodes for the provided component
api/operator/v1/vtcluster_types.go:716
↓ 7 callers
Function
CreateOrUpdate
CreateOrUpdate creates deployment for vmagent and configures it waits for healthy state
internal/controller/operator/factory/vmagent/vmagent.go:121
↓ 7 callers
Method
GetStorageVolumeName
GetStorageVolumeName returns formatted name for vtstorage volume
api/operator/v1/vtcluster_types.go:509
↓ 7 callers
Method
Load
Load returns vmanomaly config merged with provided secrets
internal/controller/operator/factory/vmanomaly/config/config.go:59
↓ 7 callers
Function
diffDeep
(desired, current any, root string)
internal/controller/operator/factory/reconcile/diff.go:117
↓ 7 callers
Function
expectPodCount
(ctx context.Context, rclient client.Client, obj client.Object, count int)
test/e2e/utils_test.go:99
↓ 7 callers
Function
isSelectorsMatchesTargetCRD
isSelectorsMatchesTargetCRD checks if targetCRD matches sourceCRD by entity selectors and selectAll. see https://docs.victoriametrics.com/operator/res
internal/controller/operator/controllers.go:239
↓ 7 callers
Function
waitForStatus
waitForStatus waits till obj reaches defined status
internal/controller/operator/factory/reconcile/reconcile.go:193
↓ 6 callers
Function
BuildLocalURL
BuildLocalURL builds API path for given args
api/operator/v1beta1/vmextra_types.go:417
↓ 6 callers
Function
ConfigMap
ConfigMap reconciles configmap object
internal/controller/operator/factory/reconcile/configmap.go:18
↓ 6 callers
Function
CreateOrUpdate
CreateOrUpdate performs an update for single node resource
internal/controller/operator/factory/vmsingle/vmsingle.go:78
↓ 6 callers
Function
FilterPrefixes
FilterPrefixes filters given prefixes from src map
internal/controller/operator/factory/converter/apis.go:529
↓ 6 callers
Function
GetTestClientWithObjectsAndInterceptors
GetTestClientWithObjectsAndInterceptors returns testing client with optional predefined objects and interceptors
internal/controller/operator/factory/k8stools/test_helpers.go:98
↓ 6 callers
Function
IsClusterWideAccessAllowed
IsClusterWideAccessAllowed checks if cluster wide access for components is needed
internal/config/config.go:955
↓ 6 callers
Method
IsProvided
IsProvided returns true if license is provided.
api/operator/v1beta1/vmextra_types.go:1056
↓ 6 callers
Function
MaybeAddArgoCDIgnoreAnnotations
MaybeAddArgoCDIgnoreAnnotations optionally adds ArgoCD annotations
internal/controller/operator/factory/converter/apis.go:89
↓ 6 callers
Function
NewReadyDeployment
NewReadyDeployment returns a new deployment with ready status condition
internal/controller/operator/factory/k8stools/test_helpers.go:194
↓ 6 callers
Function
NewReconcileRateLimiter
NewReconcileRateLimiter returns limiter with limit per 2 seconds
internal/controller/operator/factory/limiter/limiter.go:41
↓ 6 callers
Method
OperatorV1
()
api/client/versioned/clientset.go:36
↓ 6 callers
Method
PrefixedName
()
api/operator/v1beta1/vmauth_types.go:720
↓ 6 callers
Method
PrefixedName
()
api/operator/v1beta1/vmalert_types.go:456
↓ 6 callers
Method
PrefixedName
PrefixedName format name of the component with hard-coded prefix
api/operator/v1/vtsingle_types.go:274
↓ 6 callers
Method
PrefixedName
PrefixedName returns prefixed name for the given component kind
api/operator/v1/vtcluster_types.go:179
↓ 6 callers
Method
PrefixedName
PrefixedName returns prefixed name for the given component kind
api/operator/v1/vlcluster_types.go:184
↓ 6 callers
Method
RESTClient
()
api/client/versioned/typed/operator/v1/operator_client.go:29
↓ 6 callers
Function
RemoveFinalizer
RemoveFinalizer removes finalizer from instance if needed.
internal/controller/operator/factory/finalize/common.go:58
↓ 6 callers
Function
ResolveServiceURL
ResolveServiceURL returns the service name and port for building a CR's URL. When isExtra is true it targets the additional service (spec.serviceSpec)
api/operator/v1beta1/vmextra_types.go:399
↓ 6 callers
Method
String
String implements Stringer interface
api/operator/v1beta1/vmextra_types.go:1800
↓ 6 callers
Method
Validate
Validate checks if spec is correct
api/operator/v1beta1/vlogs_types.go:267
↓ 6 callers
Function
addCommonScrapeParamsTo
(cfg yaml.MapSlice, cs vmv1beta1.EndpointScrapeParams, se *vmv1beta1.CommonScrapeSecurityEnforcements)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:477
↓ 6 callers
Function
addEndpointAuthTo
(cfg yaml.MapSlice, ea *vmv1beta1.EndpointAuth, namespace string, ac *build.AssetsCache)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:552
↓ 6 callers
Function
addMetricRelabelingsTo
(cfg yaml.MapSlice, src []*vmv1beta1.RelabelConfig, se *vmv1beta1.CommonScrapeSecurityEnforcements)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:532
↓ 6 callers
Function
assertAnnotationsOnObjects
nolint:dupl,lll
test/e2e/utils_test.go:193
↓ 6 callers
Function
buildVMScrapeParams
(namespace string, cfg *vmv1beta1.VMScrapeParams, ac *build.AssetsCache)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:396
↓ 6 callers
Function
collectVMAgentScrapes
(l logr.Logger, ctx context.Context, rclient client.Client, watchNamespaces []string, instance client.Object)
internal/controller/operator/vmagent_controller.go:158
↓ 6 callers
Function
collectVMSingleScrapes
(l logr.Logger, ctx context.Context, rclient client.Client, watchNamespaces []string, instance client.Object)
internal/controller/operator/vmsingle_controller.go:149
↓ 6 callers
Function
convertSliceStruct
(src []T, convert func(T) D)
internal/controller/operator/factory/converter/v1alpha1/apis.go:206
↓ 6 callers
Function
enforceNamespaceLabel
(relabelings []yaml.MapSlice, namespace, enforcedNamespaceLabel string)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:386
↓ 6 callers
Function
getAssetsCache
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAgent)
internal/controller/operator/factory/vmagent/vmagent.go:1326
↓ 6 callers
Function
getAssetsCache
(ctx context.Context, rclient client.Client)
internal/controller/operator/factory/vmscrapes/vmscrapes_test.go:91
↓ 6 callers
Function
getScrapeClass
(name *string, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:742
↓ 6 callers
Function
hasVolumeMount
nolint:dupl,lll,unparam
test/e2e/utils_test.go:246
↓ 6 callers
Function
mergeEndpointAuthWithScrapeClass
(authz *vmv1beta1.EndpointAuth, scrapeClass *vmv1beta1.ScrapeClass)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:599
↓ 6 callers
Function
mergeMetaWithConversion
(existingObj, newObj client.Object, prevMeta *metav1.ObjectMeta, owner *metav1.OwnerReference, shouldRemoveFin
internal/controller/operator/factory/reconcile/reconcile.go:102
↓ 6 callers
Function
setScrapeIntervalToWithLimit
(ctx context.Context, dst *vmv1beta1.EndpointScrapeParams, sp *vmv1beta1.CommonScrapeParams)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:25
↓ 6 callers
Method
start
(ctx context.Context)
cmd/config-reloader/main.go:272
↓ 5 callers
Method
AsOwner
AsOwner returns owner references with current object as owner
api/operator/v1beta1/vmcluster_types.go:302
↓ 5 callers
Function
ConvertRelabelConfig
ConvertRelabelConfig converts Prometheus relabel config to VM one
internal/controller/operator/factory/converter/apis.go:305
↓ 5 callers
Function
CreateLicenseSecret
(ctx context.Context, k8sClient client.Client, namespace string)
test/e2e/common.go:16
↓ 5 callers
Function
CreateOrUpdate
CreateOrUpdate syncs VTCluster object to the desired state
internal/controller/operator/factory/vtcluster/cluster.go:21
↓ 5 callers
Function
CreateOrUpdate
CreateOrUpdate creates vmalert deployment for given CRD
internal/controller/operator/factory/vmalert/vmalert.go:100
↓ 5 callers
Function
CreateOrUpdate
CreateOrUpdate handles VM deployment reconciliation.
internal/controller/operator/factory/vmdistributed/vmdistributed.go:25
↓ 5 callers
Method
DeepCopyObject
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
api/operator/v1/zz_generated.deepcopy.go:215
↓ 5 callers
Function
GetClient
(data []byte)
test/e2e/suite/suite.go:53
↓ 5 callers
Method
HasAnyRelabellingConfigs
HasAnyRelabellingConfigs checks if vmagent has any defined relabeling rules
api/operator/v1beta1/vmagent_types.go:681
↓ 5 callers
Method
HasAnyRule
HasAnyRule returns true if there is at least one aggregation rule
api/operator/v1beta1/vmextra_types.go:711
↓ 5 callers
Method
HasAnyStreamAggrRule
HasAnyStreamAggrRule checks if vmagent has any defined aggregation rules
api/operator/v1beta1/vmagent_types.go:695
↓ 5 callers
Function
OnClusterLoadBalancerDelete
OnClusterLoadBalancerDelete removes vmauth loadbalancer components for cluster
internal/controller/operator/factory/finalize/cluster.go:139
↓ 5 callers
Function
OnInsertDelete
OnInsertDelete removes all objects related to insert component
internal/controller/operator/factory/finalize/cluster.go:54
↓ 5 callers
Function
OnSelectDelete
OnSelectDelete removes all objects related to select component
internal/controller/operator/factory/finalize/cluster.go:82
↓ 5 callers
Function
OnStorageDelete
OnStorageDelete removes all objects related to storage component
internal/controller/operator/factory/finalize/cluster.go:111
↓ 5 callers
Method
Patch
(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, subresources ...
api/client/versioned/typed/operator/v1/vlagent.go:48
↓ 5 callers
Function
PodIsReady
PodIsReady check is pod is ready
internal/controller/operator/factory/reconcile/statefulset.go:397
↓ 5 callers
Method
Port
Port returns port for accessing anomaly UI
api/operator/v1/vmanomaly_types.go:435
↓ 5 callers
Method
PrefixedName
PrefixedName format name of the component with hard-coded prefix
api/operator/v1/vmanomaly_types.go:389
↓ 5 callers
Method
PrefixedName
PrefixedName returns name of resource with fixed prefix
api/operator/v1/vlagent_types.go:425
↓ 5 callers
Function
RemoveOrphanedPDBs
RemoveOrphanedPDBs removes PDBs detached from given object
internal/controller/operator/factory/finalize/orphaned.go:48
↓ 5 callers
Method
ResourceLabels
ResourceLabels returns combination of selector, resource and managed labels
api/operator/v1/vlsingle_types.go:270
↓ 5 callers
Function
Role
Role reconciles role object
internal/controller/operator/factory/reconcile/rbac.go:57
↓ 5 callers
Function
RoleBinding
RoleBinding reconciles rolebindg object
internal/controller/operator/factory/reconcile/rbac.go:18
↓ 5 callers
Function
StatusForChildObjects
StatusForChildObjects reconciles status sub-resources Expects parentObjectName in the following form: NAME.NAMESPACE.RESOURCE for example vmalertmana
internal/controller/operator/factory/reconcile/status.go:40
↓ 5 callers
Method
VMAgentName
VMAgentName returns the name of the VMAgent for zone.
api/operator/v1alpha1/vmdistributed_types.go:140
↓ 5 callers
Method
VMClusterName
VMClusterName return cluster name for zone
api/operator/v1alpha1/vmdistributed_types.go:152
↓ 5 callers
Function
VMPodScrape
VMPodScrape creates or updates given object
internal/controller/operator/factory/reconcile/vmpodscrape.go:19
↓ 5 callers
Function
WatchUntilStatusReached
WatchUntilStatusReached starts a watch on the named object and waits until it reaches targetStatus. Uses minGen=0 (matches any generation), suitable w
test/e2e/suite/utils.go:130
↓ 5 callers
Method
close
()
cmd/config-reloader/main.go:298
↓ 5 callers
Method
close
()
cmd/config-reloader/main.go:324
↓ 5 callers
Function
getAssetsCache
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAlertmanager)
internal/controller/operator/factory/vmalertmanager/statefulset.go:448
↓ 5 callers
Function
hasVolume
nolint:dupl,lll,unparam
test/e2e/utils_test.go:233
↓ 5 callers
Function
mergeEndpointRelabelingsWithScrapeClass
(ers *vmv1beta1.EndpointRelabelings, scrapeClass *vmv1beta1.ScrapeClass)
internal/controller/operator/factory/vmscrapes/vmscrapes.go:620
↓ 5 callers
Function
newDirWatchers
newDirWatchers watches dirs; targetDirs is paired by index with dirs (dirs[i] → targetDirs[i]). If targetDirs is non-empty it must have the same lengt
cmd/config-reloader/file_watch.go:185
↓ 5 callers
Method
start
(ctx context.Context, updates chan struct{})
cmd/config-reloader/main.go:323
↓ 4 callers
Function
ClusterRole
ClusterRole reconciles cluster role object
internal/controller/operator/factory/reconcile/rbac.go:132
↓ 4 callers
Function
ClusterRoleBinding
ClusterRoleBinding reconciles cluster role binding object
internal/controller/operator/factory/reconcile/rbac.go:93
↓ 4 callers
Function
ConvertAuthorization
ConvertAuthorization converts prometheus auth struct to VM one
internal/controller/operator/factory/converter/apis.go:179
↓ 4 callers
Function
ConvertBasicAuth
ConvertBasicAuth converts Prometheus basic auth config to VM one
internal/controller/operator/factory/converter/apis.go:244
↓ 4 callers
Function
ConvertOAuth
ConvertOAuth converts prometheus OAuth config to VM one
internal/controller/operator/factory/converter/apis.go:163
↓ 4 callers
Function
ConvertSafeTLSConfig
ConvertSafeTLSConfig performs convert ConvertSafeTLSConfig to vm version
internal/controller/operator/factory/converter/apis.go:278
↓ 4 callers
Function
CreateOrUpdate
CreateOrUpdate performs an update for vtsingle resource
internal/controller/operator/factory/vtsingle/vtsingle.go:69
← previous
next →
101–200 of 3,591, ranked by callers