MCPcopy Create free account

hub / github.com/RamenDR/ramen / functions

Functions3,442 in github.com/RamenDR/ramen

⨍ Functions 3,442◇ Types & classes 274
↓ 11 callersMethodAddFinalizer
(finalizerName string)
internal/controller/util/misc.go:116
↓ 11 callersMethodFindManifestWorkByType
(mwType, managedCluster string)
internal/controller/util/mw_util.go:81
↓ 11 callersMethodGetObjectMeta
()
internal/controller/hooks/scale_hook.go:33
↓ 11 callersFunctionHasLabel
(obj client.Object, key string)
internal/controller/util/misc.go:228
↓ 11 callersFunctionRamenOperandsNamespace
(config ramendrv1alpha1.RamenConfig)
internal/controller/ramenconfig.go:532
↓ 11 callersFunctiongetDRPCCondition
(status *rmn.DRPlacementControlStatus, conditionType string)
internal/controller/drplacementcontrol_controller_test.go:1356
↓ 11 callersFunctionload_env
(args)
test/drenv/__main__.py:266
↓ 11 callersFunctionverifyDRClusterConfigMW
nolint:unparam
internal/controller/controllers_utils_test.go:389
↓ 11 callersMethodverifyVRGCondition
( inst *globalVRGInstance, condType string, expectedStatus metav1.ConditionStatus, expectedReason string, )
internal/controller/vrg_volgrouprep_global_test.go:359
↓ 10 callersMethodGenerateManifest
(obj interface{})
internal/controller/util/mw_util.go:632
↓ 10 callersFunctionListPVCsByPVCSelector
nolint:funlen
internal/controller/util/pvcs_util.go:42
↓ 10 callersMethodWithTimeout
WithTimeout returns a derived context with a deadline. Call cancel to release resources associated with the context as soon as the operation running i
e2e/app/context.go:51
↓ 10 callersMethodcleanupProtected
()
internal/controller/vrg_volrep_test.go:2727
↓ 10 callersFunctionconfigMapUpdate
( ctx context.Context, c client.Client, userConfigMap *corev1.ConfigMap, desiredRamenConfig *ramendrv1alph
internal/controller/ramenconfig.go:376
↓ 10 callersFunctioncreateNamespace
(ns *corev1.Namespace)
internal/controller/drplacementcontrol_controller_test.go:696
↓ 10 callersMethodkubeObjectsCaptureStatusFalse
(reason, message string)
internal/controller/vrg_kubeobjects.go:577
↓ 10 callersFunctionownerMatches
(obj metav1.Object, ownerName, ownerKind string, ownerIsController bool)
internal/controller/volsync/vshandler_test.go:1964
↓ 10 callersFunctionprocessAwsError
(errMsgPrefix, err error)
internal/controller/s3utils.go:411
↓ 10 callersFunctionrunRelocateAction
(placementObj client.Object, fromCluster string, isSyncDR bool, manualUnfence bool)
internal/controller/drplacementcontrol_controller_test.go:1409
↓ 10 callersMethods3KeyPrefix
s3KeyPrefix returns the S3 key prefix of cluster data of this VRG.
internal/controller/vrg_volrep.go:2385
↓ 10 callersFunctionsetVRGAutoCleanupCondition
(conditions *[]metav1.Condition, observedGeneration int64, status metav1.ConditionStatus, reason, message str
internal/controller/status.go:512
↓ 10 callersFunctiontoPointerSlice
(items []T)
internal/controller/hooks/hooks_util.go:287
↓ 9 callersMethodBuildManifestWorkName
(mwType string)
internal/controller/util/mw_util.go:73
↓ 9 callersMethodGetPods
(log logr.Logger)
internal/controller/hooks/exec_pod_lister.go:13
↓ 9 callersFunctionNewPodLister
NewPodLister returns the appropriate PodLister implementation based on SelectResource.
internal/controller/hooks/exec_pod_lister.go:17
↓ 9 callersMethodRemoveSecretFromCluster
RemoveSecretFromCluster removes the secret (secretName) in namespace, from clusterName in the format requested. If this was the last cluster that requ
internal/controller/util/secrets_util.go:746
↓ 9 callersFunctioncheckExit
(t *testing.T, exit, want int)
test/timestamp/main_test.go:147
↓ 9 callersMethodfindProtectedPVC
findProtectedPVC returns the &VRG.Status.ProtectedPVC[x] for the given pvcName
internal/controller/vrg_status_pvcs.go:13
↓ 9 callersFunctionformat_duration
Format duration in human-readable format (e.g., 7h 51m, 4m 42s).
test/drenv/stress/report.py:156
↓ 9 callersFunctiongetPodSpec
(name string)
internal/controller/hooks/exec_hook_test.go:40
↓ 9 callersMethodglobalVGRKey
--- Test helpers ---
internal/controller/vrg_volgrouprep_global_test.go:217
↓ 9 callersMethodhasGlobalVGRLabel
()
internal/controller/vrg_volgrouprep_global.go:28
↓ 9 callersFunctionisDiscoveredApp
(drpc *rmn.DRPlacementControl)
internal/controller/drplacementcontrol.go:1342
↓ 9 callersFunctionverifyDRPCStateAndProgression
(expectedAction rmn.DRAction, expectedPhase rmn.DRState, expectedPorgression rmn.ProgressionStatus, )
internal/controller/drplacementcontrol_controller_test.go:2909
↓ 8 callersFunctionConfigMapGet
( ctx context.Context, apiReader client.Reader, )
internal/controller/ramenconfig.go:431
↓ 8 callersFunctionConvertSchedulingIntervalToCronSpec
Convert from schedulingInterval which is in the format of <num><m,h,d> to the format VolSync expects, which is cronspec: https://en.wikipedia.org/wiki
internal/controller/volsync/vshandler.go:2519
↓ 8 callersMethodDeleteLabel
(key string)
internal/controller/util/misc.go:78
↓ 8 callersMethodDeleteManifestWork
(mwName, mwNamespace string)
internal/controller/util/mw_util.go:778
↓ 8 callersMethodDeployer
()
e2e/types/types.go:103
↓ 8 callersFunctionProtectedPVCNamespacedName
(pvc ramen.ProtectedPVC)
internal/controller/util/objectmeta.go:30
↓ 8 callersFunctionRequestProcessingErrorCreate
(s string)
internal/controller/kubeobjects/requests.go:153
↓ 8 callersFunctionSleep
Sleep pauses the current goroutine for at least the duration d. If the context was canceled or its deadline has exceeded it will return early with a c
e2e/util/timeout.go:77
↓ 8 callersFunctionUnifiedDiff
(t *testing.T, expected, actual any)
e2e/helpers/helpers.go:25
↓ 8 callersFunction_lookup_app_resource
(kind)
test/drenv/test.py:351
↓ 8 callersMethodcleanupStatusAbsent
()
internal/controller/vrg_volrep_test.go:2715
↓ 8 callersFunctioncreateManagedClusters
(managedClusters []*spokeClusterV1.ManagedCluster)
internal/controller/drplacementcontrol_controller_test.go:712
↓ 8 callersFunctiondeleteUserPlacementRule
nolint:unparam
internal/controller/drplacementcontrol_controller_test.go:581
↓ 8 callersFunctionexecute
Execute func in parallel for every profile. func is invoked with profile and **options. It must have this signature: def func(profi
test/drenv/__main__.py:500
↓ 8 callersFunctiongenericUpdateProtectedForCondition
genericUpdateProtectedForCondition is a common helper that processes passed in VRG condition with varying VRG reasons to determine DRPC Protected cond
internal/controller/protected_condition.go:281
↓ 8 callersFunctiongetExecPodSpec
(container string, cmd []string, pod *corev1.Pod)
internal/controller/hooks/exec_hook.go:294
↓ 8 callersFunctiongetOpHookSpec
()
internal/controller/hooks/exec_hook_test.go:60
↓ 8 callersFunctionisVRGPrimary
(vrg *rmn.VolumeReplicationGroup)
internal/controller/drplacementcontrol.go:2574
↓ 8 callersMethodrecordFailure
(ctx context.Context, drpc *rmn.DRPlacementControl, placementObj client.Object, reason, msg string, log logr.
internal/controller/drplacementcontrol_controller.go:281
↓ 8 callersFunctionselectVRGNamespace
( client client.Client, log logr.Logger, drpc *rmn.DRPlacementControl, placementObj client.Object, )
internal/controller/drplacementcontrol_controller.go:2261
↓ 8 callersFunctionsetup
(t *testing.T)
internal/controller/hooks/exec_hook_test.go:21
↓ 8 callersMethodupdateVRGConditionsAndStatus
(result ctrl.Result)
internal/controller/volumereplicationgroup_controller.go:1863
↓ 8 callersFunctionverifyActionResultForPlacement
(placement *clrapiv1beta1.Placement, homeCluster string, plType PlacementType)
internal/controller/drplacementcontrol_controller_test.go:1665
↓ 7 callersMethodCleanVolumeGroupSnapshot
Only cleanup restored pvc and volumegoupsnapshot
internal/controller/cephfscg/volumegroupsourcehandler.go:60
↓ 7 callersMethodDeleteRD
(pvcName, pvcNamespace string, skipPVCDisownership bool)
internal/controller/volsync/vshandler.go:1624
↓ 7 callersMethodFilterDRCluster
FilterDRCluster filters for DRPC resources that should be reconciled due to a DRCluster watch event
internal/controller/drplacementcontrol_watcher.go:443
↓ 7 callersFunctionGenerate
(ctx types.TestContext, recipeConfig *config.Recipe)
e2e/recipes/recipes.go:52
↓ 7 callersMethodGetAppName
()
e2e/workloads/deploy.go:47
↓ 7 callersFunctionGetCurrentCluster
GetCurrentCluster retrieves the cluster object where the workload is currently placed by looking up the cluster name from the PlacementDecision and re
e2e/util/placement.go:24
↓ 7 callersFunctionGetDRPolicy
(ctx context.Context, client client.Client, drpc *rmn.DRPlacementControl, log logr.Logger, )
internal/controller/drplacementcontrol_controller.go:668
↓ 7 callersFunctionGetRID
()
internal/controller/util/misc.go:451
↓ 7 callersFunctionInitialDeploymentAsync
(namespace, placementName, homeCluster string, plType PlacementType)
internal/controller/drplacementcontrol_controller_test.go:1005
↓ 7 callersFunctionIsReplicationGroupDestinationReady
( ctx context.Context, k8sClient client.Client, rgd *ramendrv1alpha1.ReplicationGroupDestination, )
internal/controller/util/cephfs_cg.go:34
↓ 7 callersMethodManagedClusters
ManagedClusters returns the list of managed clusters from the env.
e2e/types/env.go:24
↓ 7 callersMethodReconcileRD
returns replication destination only if create/update is successful and the RD is considered available. Callers should assume getting a nil replicatio
internal/controller/volsync/vshandler.go:167
↓ 7 callersMethodRestoreVolumesFromVolumeGroupSnapshot
( ctx context.Context, owner metav1.Object, )
internal/controller/cephfscg/volumegroupsourcehandler.go:41
↓ 7 callersMethodSynchronize
nolint:cyclop,funlen
internal/controller/cephfscg/replicationgroupdestination.go:89
↓ 7 callersFunctionWaitWorkloadHealth
(ctx types.TestContext, cluster *types.Cluster)
e2e/deployers/retry.go:49
↓ 7 callersFunction_run
(cmd, *args, env=None, context=None)
test/drenv/kubectl.py:240
↓ 7 callersFunction_watch
(cmd, *args, input=None, timeout=None, context=None, log=print)
test/drenv/kubectl.py:248
↓ 7 callersFunction_watch
(*args, stdin=None, env=None, context="lima")
test/drenv/providers/lima/__init__.py:324
↓ 7 callersMethodaddProtectedPVC
(pvcNamespace, pvcName string)
internal/controller/vrg_status_pvcs.go:23
↓ 7 callersMethodcleanup
( pvcPreDeleteVerify pvcPreDeleteVerify, )
internal/controller/vrg_volrep_test.go:2731
↓ 7 callersMethodcleanupNamespace
()
internal/controller/vrg_volrep_test.go:3010
↓ 7 callersMethodcleanupSC
()
internal/controller/vrg_volrep_test.go:2947
↓ 7 callersMethodcleanupVRC
()
internal/controller/vrg_volrep_test.go:2951
↓ 7 callersFunctioncreateDRPC
(placementName, name, namespace, drPolicyName, preferredCluster string)
internal/controller/drplacementcontrol_controller_test.go:552
↓ 7 callersMethodcreateOrUpdateManifestWork
( mw *ocmworkv1.ManifestWork, managedClusternamespace string, )
internal/controller/util/mw_util.go:669
↓ 7 callersFunctiondRPolicySupportsMetro
dRPolicySupportsMetro returns a boolean indicating that the policy supports a Metro(Sync) DR capability, and a list of list of strings, where each lis
internal/controller/drplacementcontrol.go:2415
↓ 7 callersFunctiondeleteDRClustersAsync
()
internal/controller/drplacementcontrol_controller_test.go:864
↓ 7 callersFunctionensureNamespaceMWsDeletedFromAllClusters
(namespace string)
internal/controller/drplacementcontrol_controller_test.go:596
↓ 7 callersFunctiongenPeerClass
(replicationID, storageClassName string, storageIDs []string, grouping bool, )
internal/controller/vrg_volrep_test.go:3670
↓ 7 callersMethodgetClusterDecision
(placementObj interface{}, )
internal/controller/drplacementcontrol_controller.go:1808
↓ 7 callersFunctiongetDRPC
(ctx types.TestContext, namespace, name string)
e2e/dractions/crud.go:49
↓ 7 callersFunctiongetReplicationSourceName
(pvcName string)
internal/controller/volsync/vshandler.go:2671
↓ 7 callersMethodgetStorageClass
(storageClassName *string)
internal/controller/volsync/vshandler.go:2449
↓ 7 callersMethodisCGEnabled
(pvc *corev1.PersistentVolumeClaim)
internal/controller/vrg_volgrouprep.go:663
↓ 7 callersMethodlistMCVsWithLabel
(cluster string, matchLabels map[string]string)
internal/controller/util/mcv_util.go:220
↓ 7 callersFunctionnamespaceCreate
(name string)
internal/controller/suite_test.go:104
↓ 7 callersMethodnewManifestWork
(name string, mcNamespace string, labels map[string]string, manifests []ocmworkv1.Manifest, annotations map[s
internal/controller/util/mw_util.go:644
↓ 7 callersFunctionnewRandomNamespaceSuffix
we want the math rand version here and not the crypto rand. This way we can debug the tests by repeating the seed. nolint:gosec
internal/controller/vrg_volrep_test.go:1866
↓ 7 callersFunctionnewVRGAsDataProtectedUnusedCondition
(observedGeneration int64, message string)
internal/controller/status.go:204
↓ 7 callersMethodrecordInvocation
(key string, args []interface{})
hack/fakes/fake_volume_group_source_handler.go:594
↓ 7 callersFunctionrun
(*args)
test/drenv/drenv_test.py:166
↓ 7 callersFunctionrun
(t *testing.T, program string, args ...string)
test/timestamp/main_test.go:119
↓ 7 callersFunctionrunFailoverAction
nolint:unparam
internal/controller/drplacementcontrol_controller_test.go:1371
← previousnext →101–200 of 3,442, ranked by callers