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
↓ 4 callers
Function
mustGetFirstPod
nolint:dupl,lll
test/e2e/utils_test.go:299
↓ 4 callers
Function
newDirWatchers
(dirs []string)
cmd/config-reloader/file_watch.go:123
↓ 4 callers
Function
parseRange
(s string)
api/operator/v1beta1/vmalertmanagerconfig_types.go:1386
↓ 4 callers
Function
sanitizeLabelName
(name string)
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:205
↓ 4 callers
Method
start
(ctx context.Context, updates chan struct{})
cmd/config-reloader/main.go:298
↓ 4 callers
Function
validateURLPrefix
(urlPrefixStr string)
api/operator/v1beta1/vmauth_types.go:238
↓ 4 callers
Function
waitForStatus
waitForStatus waits till obj reaches defined status
internal/controller/operator/factory/reconcile/reconcile.go:154
↓ 4 callers
Function
writeNewContent
(data []byte)
cmd/config-reloader/main.go:356
↓ 3 callers
Method
AsKey
AsKey returns unique key for object
api/operator/v1beta1/vmrule_types.go:158
↓ 3 callers
Function
ClusterRole
ClusterRole reconciles cluster role object
internal/controller/operator/factory/reconcile/rbac.go:132
↓ 3 callers
Function
ClusterRoleBinding
ClusterRoleBinding reconciles cluster role binding object
internal/controller/operator/factory/reconcile/rbac.go:93
↓ 3 callers
Function
ConvertProbe
ConvertProbe creates VMProbe from prometheus probe
internal/controller/operator/converter/apis.go:432
↓ 3 callers
Function
ConvertPromRule
ConvertPromRule creates VMRule from PrometheusRule
internal/controller/operator/converter/apis.go:25
↓ 3 callers
Function
ConvertServiceMonitor
ConvertServiceMonitor create VMServiceScrape from ServiceMonitor
internal/controller/operator/converter/apis.go:104
↓ 3 callers
Function
CreateOrUpdate
CreateOrUpdate syncs VTCluster object to the desired state
internal/controller/operator/factory/vtcluster/cluster.go:21
↓ 3 callers
Function
CreateOrUpdate
CreateOrUpdate performs an update for vtsingle resource
internal/controller/operator/factory/vtsingle/vtsingle.go:67
↓ 3 callers
Function
CreateOrUpdate
CreateOrUpdate - handles VMAuth deployment reconciliation.
internal/controller/operator/factory/vmauth/vmauth.go:44
↓ 3 callers
Function
CreateOrUpdateAlertManager
CreateOrUpdateAlertManager creates alertmanager and builds config for it
internal/controller/operator/factory/vmalertmanager/alertmanager.go:24
↓ 3 callers
Function
DaemonSet
DaemonSet performs an update or create operator for daemonset and waits until it finishes update rollout
internal/controller/operator/factory/reconcile/daemonset.go:21
↓ 3 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAgent.
api/operator/v1beta1/zz_generated.deepcopy.go:4131
↓ 3 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAlert.
api/operator/v1beta1/zz_generated.deepcopy.go:4457
↓ 3 callers
Function
GetInterceptorsWithObjects
GetInterceptorsWithObjects returns interceptors for objects
internal/controller/operator/factory/k8stools/interceptors.go:60
↓ 3 callers
Method
GetMinReplicas
GetMinReplicas returns default minReplicas value
api/operator/v1beta1/vmextra_types.go:439
↓ 3 callers
Method
GetNamespace
()
api/operator/v1beta1/vmservicescrape_types.go:103
↓ 3 callers
Method
GetRemoteWriteURL
GetRemoteWriteURL returns remote write url for VMCluster
api/operator/v1beta1/vmcluster_types.go:630
↓ 3 callers
Method
HasAnyStreamAggrRule
HasAnyStreamAggrRule checks if vmagent has any defined aggregation rules
api/operator/v1beta1/vmagent_types.go:678
↓ 3 callers
Function
InitOperatorProcess
InitOperatorProcess prepares operator process for usage, must be called once
test/e2e/suite/suite.go:171
↓ 3 callers
Method
IsProvided
IsProvided returns true if license is provided.
api/operator/v1beta1/vmextra_types.go:787
↓ 3 callers
Method
KeepHPA
KeepHPA adds given HorizontalPodAutoscaler's name to a map of resource names to be excluded from deletion
internal/controller/operator/factory/finalize/cluster.go:189
↓ 3 callers
Method
KeepPDB
KeepPDB adds given PodDisruptionBudget's name to a map of resource names to be excluded from deletion
internal/controller/operator/factory/finalize/cluster.go:184
↓ 3 callers
Method
KeepScrape
KeepScrape adds given VMServiceScrape's name to a map of resource names to be excluded from deletion
internal/controller/operator/factory/finalize/cluster.go:204
↓ 3 callers
Method
KeepService
KeepService adds given HorizontalPodAutoscaler's name to a map of resource names to be excluded from deletion
internal/controller/operator/factory/finalize/cluster.go:199
↓ 3 callers
Method
KeepVPA
KeepVPA adds given VerticalPodAutoscaler's name to a map of resource names to be excluded from deletion
internal/controller/operator/factory/finalize/cluster.go:194
↓ 3 callers
Function
NewActionRecordingInterceptor
NewActionRecordingInterceptor returns an interceptor that records actions to the provided slice pointer. It wraps an existing interceptorFuncs if prov
internal/controller/operator/factory/k8stools/interceptors.go:89
↓ 3 callers
Function
NewChildCleaner
NewChildCleaner initializes ChildCleaner
internal/controller/operator/factory/finalize/cluster.go:173
↓ 3 callers
Function
OnClusterDelete
(ctx context.Context, rclient client.Client, cr build.ParentOpts)
internal/controller/operator/factory/finalize/cluster.go:21
↓ 3 callers
Method
Paused
()
internal/controller/operator/controllers.go:274
↓ 3 callers
Method
Port
Port returns port for accessing alertmanager
api/operator/v1beta1/vmalertmanager_types.go:378
↓ 3 callers
Method
Port
Port returns port for accessing anomaly UI
api/operator/v1/vmanomaly_types.go:414
↓ 3 callers
Method
PrefixedName
()
api/operator/v1beta1/vmauth_types.go:664
↓ 3 callers
Method
PrefixedName
()
api/operator/v1beta1/vmalert_types.go:442
↓ 3 callers
Method
PrefixedName
()
api/operator/v1beta1/vlogs_types.go:246
↓ 3 callers
Method
PrefixedName
()
api/operator/v1/vlsingle_types.go:267
↓ 3 callers
Method
PrefixedName
PrefixedName format name of the component with hard-coded prefix
api/operator/v1/vtsingle_types.go:262
↓ 3 callers
Method
PrefixedName
PrefixedName returns prefixed name for the given component kind
api/operator/v1/vtcluster_types.go:173
↓ 3 callers
Method
PrefixedName
PrefixedName returns prefixed name for the given component kind
api/operator/v1/vlcluster_types.go:178
↓ 3 callers
Method
RemoveOrphaned
RemoveOrphaned removes cr dependent resources excluding ones, which are defined in cleaner's maps
internal/controller/operator/factory/finalize/cluster.go:209
↓ 3 callers
Function
RemoveOrphanedDeployments
RemoveOrphanedDeployments removes Deployments detached from given object
internal/controller/operator/factory/finalize/orphaned.go:19
↓ 3 callers
Function
RemoveOrphanedVMPodScrapes
RemoveOrphanedVMPodScrapes removes VMPodScrapes detached from given object
internal/controller/operator/factory/finalize/orphaned.go:106
↓ 3 callers
Method
SelectorLabels
()
api/operator/v1beta1/vmagent_types.go:504
↓ 3 callers
Function
ShutdownOperatorProcess
ShutdownOperatorProcess stops operator process and cleanup resources
test/e2e/suite/suite.go:194
↓ 3 callers
Method
SubResource
(subResource string)
internal/manager/client.go:49
↓ 3 callers
Method
UseTLS
UseTLS returns true if TLS is enabled
api/operator/v1/vlagent_types.go:423
↓ 3 callers
Function
VMAuth
VMAuth performs an update or create of VMAuth and till it's ready
internal/controller/operator/factory/reconcile/vmauth.go:18
↓ 3 callers
Method
VMAuthName
VMAuthName returns the name of the VMAuth resource to be created/managed.
api/operator/v1alpha1/vmdistributed_types.go:356
↓ 3 callers
Method
WaitForCacheSync
WaitForCacheSync blocks until all started informers' caches were synced or the stop channel gets closed.
api/client/informers/externalversions/factory.go:248
↓ 3 callers
Method
addLabel
(name string, value string)
test/e2e/suite/allure/result.go:72
↓ 3 callers
Function
assertStrictSecurity
(podSpec corev1.PodSpec)
test/e2e/vmcluster_test.go:2016
↓ 3 callers
Function
convertBearerToken
(src *corev1.SecretKeySelector)
internal/controller/operator/converter/apis.go:197
↓ 3 callers
Function
convertSecretOrConfigmap
(promSCM promv1.SecretOrConfigMap)
internal/controller/operator/converter/apis.go:298
↓ 3 callers
Function
diffDeepInternal
diffDeepInternal is similar to diffDeep except that unset fields in desired are ignored (not compared). This allows us to focus on the fields that mat
internal/controller/operator/factory/reconcile/diff.go:132
↓ 3 callers
Function
expectHTTPRequestToSucceed
nolint:dupl,lll
test/e2e/utils_test.go:151
↓ 3 callers
Function
getAssetsCache
(ctx context.Context, rclient client.Client, cr *vmv1beta1.VMAlert)
internal/controller/operator/factory/vmalert/vmalert.go:81
↓ 3 callers
Function
getEnvOpts
()
internal/config/config.go:46
↓ 3 callers
Function
getNamespacesFromNamespaceSelector
getNamespacesFromNamespaceSelector gets a list of namespaces to select based on the given namespace selector, the given default namespace, and whether
internal/controller/operator/factory/vmagent/vmagent_scrapeconfig.go:356
↓ 3 callers
Function
getTimestampMsFromTime
(t time.Time)
test/e2e/suite/allure/misc.go:29
↓ 3 callers
Function
getZones
getZones builds desired zones
internal/controller/operator/factory/vmdistributed/zone.go:72
↓ 3 callers
Function
isStorageEmpty
(pvc *corev1.PersistentVolumeClaimSpec)
internal/controller/operator/factory/vtsingle/vtsingle.go:32
↓ 3 callers
Function
isStorageEmpty
(pvc *corev1.PersistentVolumeClaimSpec)
internal/controller/operator/factory/vlsingle/vlsingle.go:32
↓ 3 callers
Function
isStorageEmpty
(pvc *corev1.PersistentVolumeClaimSpec)
internal/controller/operator/factory/vmsingle/vmsingle.go:33
↓ 3 callers
Function
newPodSpec
(cr *vmv1beta1.VMAgent, ac *build.AssetsCache)
internal/controller/operator/factory/vmagent/vmagent.go:487
↓ 3 callers
Function
patchReplaceFinalizers
(ctx context.Context, rclient client.Client, instance client.Object)
internal/controller/operator/factory/finalize/common.go:23
↓ 3 callers
Function
readFileContent
(src string)
cmd/config-reloader/file_watch.go:113
↓ 3 callers
Function
reportFirstNotReadyPodOnError
(ctx context.Context, rclient client.Client, origin error, ns string, selector labels.Selector, minReadySecond
internal/controller/operator/factory/reconcile/deploy.go:137
↓ 3 callers
Function
selectUsers
selects vmusers for given vmauth.
internal/controller/operator/factory/vmauth/vmusers_config.go:854
↓ 3 callers
Function
validateHTTPHeaders
(headerValues []string)
api/operator/v1beta1/vmauth_types.go:383
↓ 3 callers
Function
validateStatefulSet
validateStatefulSet performs validation Statefulset spec Kubernetes doesn't perform some checks and produces runtime error during Pod creation. Volume
internal/controller/operator/factory/reconcile/statefulset.go:533
↓ 2 callers
Function
AddClusterLabels
AddClusterLabels adds to given labels cluster specific labels
api/operator/v1beta1/vmextra_types.go:101
↓ 2 callers
Method
AsConfigMapKey
AsConfigMapKey key for kubernetes configmap
api/operator/v1beta1/vmagent_types.go:401
↓ 2 callers
Function
ClusterPrefixedName
ClusterPrefixedName defines prefixed name for given cluster component kind
api/operator/v1beta1/vmextra_types.go:127
↓ 2 callers
Function
ConvertPodMonitor
ConvertPodMonitor create VMPodScrape from PodMonitor
internal/controller/operator/converter/apis.go:387
↓ 2 callers
Function
ConvertTLSConfig
ConvertTLSConfig converts Prometheus TLS config to VM one
internal/controller/operator/converter/apis.go:256
↓ 2 callers
Function
CreateObjects
(objects ...client.Object)
test/e2e/watchnamespace/utils_test.go:13
↓ 2 callers
Function
CreateOrUpdate
CreateOrUpdate performs an update for vlsingle resource
internal/controller/operator/factory/vlsingle/vlsingle.go:67
↓ 2 callers
Function
CreateOrUpdate
CreateOrUpdate creates deployment for vlagent and configures it waits for healthy state
internal/controller/operator/factory/vlagent/vlagent.go:86
↓ 2 callers
Function
CreateOrUpdate
CreateOrUpdate syncs VLCluster object to the desired state
internal/controller/operator/factory/vlcluster/vlcluster.go:21
↓ 2 callers
Function
CreateOrUpdateConfig
CreateOrUpdateConfig configuration secret for vmauth.
internal/controller/operator/factory/vmauth/vmauth.go:389
↓ 2 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAlertmanager.
api/operator/v1beta1/zz_generated.deepcopy.go:4738
↓ 2 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAlertmanagerConfig.
api/operator/v1beta1/zz_generated.deepcopy.go:4765
↓ 2 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAuth.
api/operator/v1beta1/zz_generated.deepcopy.go:5139
↓ 2 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMSingle.
api/operator/v1beta1/zz_generated.deepcopy.go:6639
↓ 2 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VLAgent.
api/operator/v1/zz_generated.deepcopy.go:209
↓ 2 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VLCluster.
api/operator/v1/zz_generated.deepcopy.go:535
↓ 2 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VLSingle.
api/operator/v1/zz_generated.deepcopy.go:788
↓ 2 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMAnomaly.
api/operator/v1/zz_generated.deepcopy.go:1013
↓ 2 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VTCluster.
api/operator/v1/zz_generated.deepcopy.go:1354
↓ 2 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VTSingle.
api/operator/v1/zz_generated.deepcopy.go:1597
↓ 2 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VMDistributed.
api/operator/v1alpha1/zz_generated.deepcopy.go:41
↓ 2 callers
Function
DeleteAllObjectsOf
(namespace string, listProtos ...client.ObjectList)
test/e2e/watchnamespace/utils_test.go:19
↓ 2 callers
Method
DeleteAllOf
(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption)
internal/manager/client.go:44
← previous
next →
201–300 of 3,239, ranked by callers