MCPcopy Create free account

hub / github.com/RamenDR/ramen / functions

Functions3,442 in github.com/RamenDR/ramen

↓ 940 callersMethodErrorf
Errorf writes a formatted error message to the log and markd the test as failed.
e2e/test/testing.go:42
↓ 592 callersMethodGetName
()
e2e/types/types.go:49
↓ 416 callersMethodError
()
internal/controller/kubeobjects/requests.go:154
↓ 407 callersMethodGet
(i int)
internal/controller/kubeobjects/requests.go:32
↓ 302 callersMethodCreate
(event.CreateEvent)
internal/controller/util/predicates.go:40
↓ 215 callersMethodUpdate
(ctx context.Context, client client.Client)
internal/controller/hooks/scale_hook.go:34
↓ 214 callersMethodGetNamespace
GetNamespace return the namespace for the ramen resources, or empty string if not using a special namespace.
e2e/types/types.go:51
↓ 163 callersMethodDelete
(event.DeleteEvent)
internal/controller/util/predicates.go:41
↓ 115 callersMethodDeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
api/v1alpha1/zz_generated.deepcopy.go:1501
↓ 108 callersMethodGetAnnotations
()
internal/controller/hooks/scale_hook.go:31
↓ 100 callersMethodEnv
()
e2e/types/types.go:94
↓ 98 callersMethodDeepCopy
DeepCopy is for copying the receiver, creating a new ClusterStatus.
internal/controller/util/secrets_util.go:248
↓ 83 callersFunctionAddLabel
(obj client.Object, key, value string)
internal/controller/util/misc.go:166
↓ 76 callersMethodStatus
(logr.Logger)
internal/controller/kubeobjects/requests.go:26
↓ 67 callersFunctionobjectConditionExpectEventually
( apiReader client.Reader, obj client.Object, status metav1.ConditionStatus, reasonMatcher, messageMatche
internal/controller/controllers_utils_test.go:179
↓ 61 callersMethodLogger
()
e2e/types/types.go:93
↓ 53 callersMethodAppNamespace
Namespace for application resources on the managed clusters.
e2e/types/types.go:112
↓ 53 callersMethodEqual
Equal return true if config is equal to other config. nolint:cyclop
e2e/config/config.go:507
↓ 51 callersMethodContext
()
e2e/types/types.go:96
↓ 47 callersFunctionSetStatusCondition
(existingConditions *[]metav1.Condition, newCondition metav1.Condition)
internal/controller/util/conditions.go:215
↓ 42 callersMethodFatalf
Fatalf writes a formatted error message to the log and fail the text immediately.
e2e/test/testing.go:54
↓ 40 callersFunctionaddOrUpdateCondition
(conditions *[]metav1.Condition, conditionType string, observedGeneration int64, status metav1.ConditionStatu
internal/controller/drplacementcontrol_controller.go:2284
↓ 40 callersMethodupdatePVCDataReadyCondition
(pvcNamespace, pvcName, reason, message string)
internal/controller/vrg_volrep.go:2139
↓ 36 callersMethodsetProgression
* DRPC Status.Progression has several distinct progressions depending on the action being performed. The following comment is to help identify which p
internal/controller/drplacementcontrol.go:3047
↓ 35 callersMethodWorkload
()
e2e/types/types.go:104
↓ 34 callersMethodManagementNamespace
Namespace for OCM and Ramen resources (Subscription, ApplicationSet, DRPC, VRG) on the hub and managed clusters. Depending on the deployer, it may be
e2e/types/types.go:109
↓ 32 callersMethodConfig
()
e2e/types/types.go:95
↓ 29 callersMethodName
()
e2e/types/types.go:105
↓ 28 callersFunctionGetVolSyncPSKSecretNameFromVRGName
(vrgName string)
internal/controller/volsync/secret_propagator.go:25
↓ 27 callersMethodAddLabel
(key, value string)
internal/controller/util/misc.go:70
↓ 27 callersFunctiongenStorageIDLabel
(storageID string)
internal/controller/vrg_volrep_test.go:3664
↓ 26 callersFunctionensureClassStatus
(apiReader client.Reader, drCConfig *ramen.DRClusterConfig, classes Classes, )
internal/controller/drclusterconfig_controller_test.go:67
↓ 26 callersFunctiongenVRCLabels
nolint:unparam
internal/controller/vrg_volrep_test.go:3687
↓ 25 callersFunctiongetManifestWorkCount
(homeClusterNamespace string)
internal/controller/drplacementcontrol_controller_test.go:1112
↓ 25 callersMethodverifyVRGStatusExpectation
(expectedStatus bool, reason string)
internal/controller/vrg_volrep_test.go:2476
↓ 24 callersFunctionAddAnnotation
(obj client.Object, key, value string)
internal/controller/util/misc.go:261
↓ 24 callersMethodrequeue
()
internal/controller/volumereplicationgroup_controller.go:620
↓ 24 callersMethodwaitForVRCountToMatch
(vrCount int)
internal/controller/vrg_volrep_test.go:3020
↓ 23 callersMethodGetAppName
()
e2e/types/types.go:74
↓ 23 callersFunctionNewVSHandler
(ctx context.Context, client client.Client, log logr.Logger, owner metav1.Object, asyncSpec *ramendrv1alpha1.
internal/controller/volsync/vshandler.go:94
↓ 23 callersFunctionupdateDRClusterManifestWorkStatus
(k8sClient client.Client, apiReader client.Reader, clusterNamespace string)
internal/controller/controllers_utils_test.go:113
↓ 22 callersMethodError
Error writes an error message to the log and mark the test as failed.
e2e/test/testing.go:36
↓ 22 callersFunctionRamenOperatorNamespace
()
internal/controller/ramenconfig.go:455
↓ 22 callersFunctiondelete
Run kubectl delete ... logging progress messages.
test/drenv/kubectl.py:137
↓ 22 callersFunctiongetLatestDRPC
(namespace string)
internal/controller/drplacementcontrol_controller_test.go:643
↓ 22 callersFunctionmakeDRPCWithLabel
(name, namespace, vgrLabel string, action rmn.DRAction, failover, preferred string, )
internal/controller/drpc_predicate_test.go:501
↓ 21 callersFunctionResourceIsDeleted
Return true if resource was marked for deletion.
internal/controller/util/objectmeta.go:26
↓ 21 callersMethodgetVRG
()
internal/controller/vrg_volrep_test.go:2441
↓ 21 callersFunctionnewVRGTestCaseCreateAndStart
newVRGTestCaseCreateAndStart creates a new namespace, zero or more PVCs (equal to the input pvcCount), a PV for each PVC, and a VRG in primary state,
internal/controller/vrg_volrep_test.go:1946
↓ 20 callersMethodEnsureConfigMap
EnsureConfigMap ensures the default excluded resources ConfigMap exists. If it doesn't exist, it creates one with the default hardcoded values. Return
internal/controller/kubeobjects/velero/exclude_resources.go:83
↓ 19 callersFunctionNewExcludedResourcesManager
NewExcludedResourcesManager creates a new ExcludedResourcesManager
internal/controller/kubeobjects/velero/exclude_resources.go:72
↓ 19 callersFunctionupdateDRClusterConfigMWStatus
(k8sClient client.Client, apiReader client.Reader, clusterNamespace string)
internal/controller/controllers_utils_test.go:122
↓ 18 callersFunctionNewResourceUpdater
(obj client.Object)
internal/controller/util/misc.go:62
↓ 18 callersMethodSetAnnotations
(map[string]string)
internal/controller/hooks/scale_hook.go:32
↓ 18 callersFunctionupdateDRClusterParameters
(drc *ramen.DRCluster)
internal/controller/controllers_utils_test.go:91
↓ 17 callersFunctionBuildManagedClusterViewName
outputs a string for use in creating a ManagedClusterView name example: when looking for a vrg with name 'demo' in the namespace 'ramen', input: ("dem
internal/controller/util/mcv_util.go:454
↓ 17 callersFunctionConvertCommandToStringArray
(command string)
internal/controller/hooks/exec_hook.go:313
↓ 17 callersFunctionNewVSCGHandler
( ctx context.Context, k8sClient client.Client, instance *ramendrv1alpha1.VolumeReplicationGroup, volumeGr
internal/controller/cephfscg/cghandler.go:27
↓ 17 callersFunctionadd_command
(sp, name, func, help=None, envfile=True)
test/drenv/__main__.py:248
↓ 17 callersMethodgetConditionStatusForTypeAvailable
()
internal/controller/drplacementcontrol.go:3151
↓ 17 callersFunctiongetHookSpec
(resourceType, condition string)
internal/controller/hooks/check_hook_test.go:255
↓ 17 callersFunctionsetupFakeClient
setupFakeClient creates a fake client with corev1 scheme
internal/controller/kubeobjects/velero/exclude_resources_test.go:30
↓ 17 callersFunctionwaitForCompletion
(expectedState string)
internal/controller/drplacementcontrol_controller_test.go:1339
↓ 16 callersMethodAddSecretToCluster
AddSecretToCluster takes in a secret (secretName) in the Ramen S3 secret format in a namespace and uses OCM Policy to deliver it to the desired cluste
internal/controller/util/secrets_util.go:699
↓ 16 callersMethodDeleteObjectsWithKeyPrefix
(keyPrefix string)
internal/controller/s3utils.go:99
↓ 16 callersFunctionHavePVCName
HavePVCName returns a matcher that expects the PVC to have the given name.
internal/controller/util/pvcs_util_test.go:262
↓ 16 callersMethodSetupWithManager
SetupWithManager sets up the controller with the Manager.
internal/controller/drpolicy_controller.go:498
↓ 16 callersFunctioncheckTimestampStream
(t *testing.T, got string, want ...string)
test/timestamp/main_test.go:163
↓ 16 callersFunctionpopulateDRClusters
()
internal/controller/drplacementcontrol_controller_test.go:733
↓ 16 callersFunctionrun
(*args, stdin=None, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
test/drenv/commands_test.py:737
↓ 15 callersFunctionFindCondition
(existingConditions []metav1.Condition, conditionType string)
internal/controller/util/conditions.go:254
↓ 15 callersFunctionIsDiffSyncEnabled
IsDiffSyncEnabled checks if the enable-diff annotation is set to true on the resource
internal/controller/util/misc.go:419
↓ 15 callersFunctiondeleteDRPC
()
internal/controller/drplacementcontrol_controller_test.go:591
↓ 15 callersMethodgetLastDRState
()
internal/controller/drplacementcontrol.go:3193
↓ 15 callersMethods3KeyPrefix
()
internal/controller/vrg_volrep_test.go:2037
↓ 15 callersFunctionvrgGet
(vrgNamespacedName types.NamespacedName)
internal/controller/vrg_volrep_test.go:2457
↓ 14 callersMethodObjectStore
ObjectStore returns an object that satisfies ObjectStorer interface
internal/controller/s3utils.go:88
↓ 14 callersMethodvrgNamespacedName
()
internal/controller/vrg_volrep_test.go:2033
↓ 13 callersMethodAddAnnotation
(key, value string)
internal/controller/util/misc.go:93
↓ 13 callersMethodCreateOrUpdateVolumeGroupSnapshot
( ctx context.Context, owner metav1.Object, )
internal/controller/cephfscg/volumegroupsourcehandler.go:37
↓ 13 callersMethodObject
()
internal/controller/kubeobjects/requests.go:22
↓ 13 callersFunctionOwnerLabels
(owner metav1.Object)
internal/controller/util/labels.go:58
↓ 13 callersMethodReconcileRS
Returns true only if runFinalSync is true and the final sync is done Returns replication source only if create/update is successful Callers should ass
internal/controller/volsync/vshandler.go:498
↓ 13 callersMethodRemoveFinalizer
(finalizerName string)
internal/controller/util/misc.go:146
↓ 13 callersMethodgetPVC
(pvcNamespacedName types.NamespacedName)
internal/controller/volsync/vshandler.go:1339
↓ 13 callersFunctioninfo
(fmt, *args)
test/drenv/test.py:89
↓ 13 callersFunctionsetDRPCSpecExpectationTo
(namespace, preferredCluster, failoverCluster string, action rmn.DRAction)
internal/controller/drplacementcontrol_controller_test.go:615
↓ 13 callersMethodsetDRState
(nextState rmn.DRState)
internal/controller/drplacementcontrol.go:2946
↓ 12 callersFunctionDRPolicyClusterNames
(drpolicy *rmn.DRPolicy)
internal/controller/util/drpolicy_util.go:22
↓ 12 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Sync.
api/v1alpha1/zz_generated.deepcopy.go:1513
↓ 12 callersMethodDeepCopyInto
DeepCopyInto is for copying the receiver, writing into out. in must be non-nil.
internal/controller/util/secrets_util.go:261
↓ 12 callersMethodFatal
Fatal writes an error message to the log and fail the text immediately.
e2e/test/testing.go:48
↓ 12 callersFunctionGetLocalReplicationName
(pvcName string)
internal/controller/util/misc.go:491
↓ 12 callersFunctionGetReplicationDestinationName
(pvcName string)
internal/controller/util/misc.go:487
↓ 12 callersMethodIs
Called by errors.Is() to match target.
internal/controller/kubeobjects/requests.go:157
↓ 12 callersFunctionWithLog
WithLog returns a t wrapped with a specified log. nolint:thelper
e2e/test/testing.go:21
↓ 12 callersFunctioncreateConfigMapWithJSON
createConfigMapWithJSON creates a ConfigMap with JSON-formatted excluded resources
internal/controller/kubeobjects/velero/exclude_resources_test.go:41
↓ 12 callersMethodgetResourceFromManagedCluster
getResourceFromManagedCluster gets the resource named resourceName in the resourceNamespace (empty if cluster scoped) with the passed in group, versio
internal/controller/util/mcv_util.go:122
↓ 12 callersMethodpromoteVolReps
()
internal/controller/vrg_volrep_test.go:3130
↓ 12 callersMethodupdatePVCDataProtectedCondition
(pvcNamespace, pvcName, reason, message string)
internal/controller/vrg_volrep.go:2148
next →1–100 of 3,442, ranked by callers