MCPcopy Create free account

hub / github.com/RamenDR/ramen / functions

Functions3,442 in github.com/RamenDR/ramen

⨍ Functions 3,442◇ Types & classes 274
↓ 7 callersMethodsetDRClusterPhase
(nextPhase ramen.DRClusterPhase)
internal/controller/drcluster_controller.go:1711
↓ 7 callersMethodupdatePreferredDecision
()
internal/controller/drplacementcontrol.go:1906
↓ 7 callersMethodvalidatedSetFalseAndUpdate
(reason string, err error)
internal/controller/drcluster_controller.go:669
↓ 7 callersFunctionvrgInAdminNamespace
(vrg *ramendrv1alpha1.VolumeReplicationGroup, ramenConfig *ramendrv1alpha1.RamenConfig)
internal/controller/volumereplicationgroup_controller.go:2311
↓ 7 callersFunctionwaitForGlobalDRPCCondition
(namespace string, expected metav1.ConditionStatus)
internal/controller/drplacementcontrol_global_test.go:223
↓ 7 callersFunctionwaitForResourceDelete
waitForResourceDelete waits until a resource is deleted or deadline is reached
e2e/util/wait.go:137
↓ 6 callersFunctionCheckImagesReadyToUse
( ctx context.Context, k8sClient client.Client, latestImages map[string]*corev1.TypedLocalObjectReference,
internal/controller/util/cephfs_cg.go:271
↓ 6 callersMethodContextName
ContextName returns the test context name. If Name is set, it is returned as-is. Otherwise, a name is generated from the deployer, workload, and pvcSp
e2e/config/config.go:139
↓ 6 callersMethodDeepCopyObject
DeepCopyObject interfaces required to use localSecret as a runtime.Object Lifted from generated deep copy file for other resources
internal/controller/util/secrets_util.go:243
↓ 6 callersMethodDeleteRS
(pvcName string, pvcNamespace string, skipPVCDisownership bool)
internal/controller/volsync/vshandler.go:1487
↓ 6 callersMethodDownloadObject
(key string, objectPointer interface{})
internal/controller/s3utils.go:95
↓ 6 callersFunctionGenerateCombinedName
GenerateCombinedName returns a string in the form "name-storageID", ensuring the total length does not exceed MaxK8sLabelLength. If the combined lengt
internal/controller/util/misc.go:465
↓ 6 callersFunctionGeneratePolicyResourceNames
GeneratePolicyResourceNames returns names (in order) for policy resources that are created, policyName: Name of the policy plBindingName: Name of the
internal/controller/util/secrets_util.go:80
↓ 6 callersMethodGetAppName
()
e2e/workloads/vm.go:41
↓ 6 callersFunctionGetDRClusters
(ctx context.Context, client client.Client, drPolicy *rmn.DRPolicy)
internal/controller/drplacementcontrol_controller.go:685
↓ 6 callersFunctionGetJobName
(namePrefix string, ownerName string)
internal/controller/util/misc.go:432
↓ 6 callersFunctionGetTmpPVCNameForFinalSync
(pvcName string)
internal/controller/util/pvcs_util.go:400
↓ 6 callersFunctionGetVolumeGroupSnapshotClassFromPVCsStorageClass
( ctx context.Context, k8sClient client.Client, volumeGroupSnapshotClassSelector metav1.LabelSelector, pvc
internal/controller/util/cephfs_cg.go:100
↓ 6 callersMethodIsCopyMethodDirect
()
internal/controller/volsync/vshandler.go:2659
↓ 6 callersFunctionIsPVCMarkedForVolSync
(annotations map[string]string)
internal/controller/util/misc.go:414
↓ 6 callersFunctionMerge
Merge merges system and user RamenConfig YAML. Fields present in userYAML override the corresponding fields in systemYAML; fields missing from userYAM
internal/config/config.go:15
↓ 6 callersMethodName
()
internal/controller/kubeobjects/requests.go:23
↓ 6 callersFunctionNewRGDMachine
( client client.Client, replicationGroupDestination *ramendrv1alpha1.ReplicationGroupDestination, vsHandler
internal/controller/cephfscg/replicationgroupdestination.go:33
↓ 6 callersMethodPrecreateDestPVCIfEnabled
(rdSpec ramendrv1alpha1.VolSyncReplicationDestinationSpec, )
internal/controller/volsync/vshandler.go:2619
↓ 6 callersFunctionSetStatusConditionIfNotFound
(existingConditions *[]metav1.Condition, newCondition metav1.Condition)
internal/controller/util/conditions.go:201
↓ 6 callersMethodVRGTestCaseStart
()
internal/controller/vrg_volrep_test.go:1913
↓ 6 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/test/context.go:87
↓ 6 callersFunction_watch
(command, *args, profile=None)
test/drenv/providers/minikube/__init__.py:481
↓ 6 callersMethodaddAnnotationForResource
(resource client.Object, resourceType, annotationKey, annotationValue string, log logr.Logger, )
internal/controller/vrg_volgrouprep.go:152
↓ 6 callersFunctionclearDRPCStatus
()
internal/controller/drplacementcontrol_controller_test.go:655
↓ 6 callersFunctioncreateBoundPVCAndPV
(namespace, scName, suffix string)
internal/controller/vrg_volgrouprep_global_test.go:271
↓ 6 callersFunctioncreateDummyPVC
(pvcName, namespace string, capacity resource.Quantity, annotations map[string]string, )
internal/controller/volsync/vshandler_test.go:2001
↓ 6 callersFunctiondeleteDRPolicyAsync
()
internal/controller/drplacementcontrol_controller_test.go:868
↓ 6 callersFunctionensureDRClusterConfigMWNotFound
(k8sClient client.Client, managedCluster string, always bool)
internal/controller/controllers_utils_test.go:457
↓ 6 callersFunctionfilterVRGDependentObjects
(reader client.Reader, obj client.Object, log logr.Logger, )
internal/controller/volumereplicationgroup_controller.go:2317
↓ 6 callersMethodgenerateArchiveAnnotation
(gen int64)
internal/controller/vrg_volrep.go:693
↓ 6 callersFunctiongetDeploymentContent
()
internal/controller/hooks/check_hook_test.go:627
↓ 6 callersFunctiongetFunctionNameAtIndex
nolint:dogsled
internal/controller/drplacementcontrol_controller_test.go:204
↓ 6 callersMethodgetPVFromPVC
(pvc *corev1.PersistentVolumeClaim)
internal/controller/vrg_volrep.go:950
↓ 6 callersFunctiongetPlacementDecision
(plName, plNamespace string)
internal/controller/drplacementcontrol_controller_test.go:1196
↓ 6 callersFunctiongetPodContent
()
internal/controller/hooks/check_hook_test.go:594
↓ 6 callersFunctiongetResourcesUsingLabelSelector
(r client.Reader, hook *kubeobjects.HookSpec, objList client.ObjectList, )
internal/controller/hooks/hooks_util.go:182
↓ 6 callersMethodgetVRGFromManifestWork
(clusterName string)
internal/controller/drplacementcontrol.go:1799
↓ 6 callersFunctiongetVRGManifestWorkCount
()
internal/controller/drplacementcontrol_controller_test.go:2870
↓ 6 callersFunctionisVRConditionMet
isVRConditionMet check if condition is met. Returns 3 values: - met: true if the condition status matches the desired status, otherwise false - state:
internal/controller/vrg_volrep.go:2103
↓ 6 callersMethodlogAndSetConditions
(conditionName string, subconditions ...*metav1.Condition)
internal/controller/volumereplicationgroup_controller.go:2077
↓ 6 callersFunctionnewVRGTestCaseCreate
(pvcCount int, testTemplate *template, checkBind, vrgFirst bool)
internal/controller/vrg_volrep_test.go:1876
↓ 6 callersMethodpreparePVCForVRDeletion
preparePVCForVRDeletion
internal/controller/vrg_volrep.go:592
↓ 6 callersFunctionpruneClassViews
pruneClassViews prunes existing views in mcvs, for classes that are not found in survivorClassNames
internal/controller/drpolicy_peerclass.go:556
↓ 6 callersFunctionresetClusterDown
()
internal/controller/drplacementcontrol_controller_test.go:249
↓ 6 callersFunctionsecretsFromSC
(params map[string]string, secretName, secretNamespace string, )
internal/controller/vrg_volrep.go:2797
↓ 6 callersFunctionupdateGlobalMWStatus
(clusterNS, vrgNS string)
internal/controller/drplacementcontrol_global_test.go:181
↓ 6 callersMethodupdatePVCClusterDataProtectedCondition
(pvcNamespace, pvcName, reason, message string)
internal/controller/vrg_volrep.go:2213
↓ 6 callersMethodupdateResource
(obj client.Object, mutateFn func(obj client.Object) error)
internal/controller/volsync/vshandler.go:3212
↓ 6 callersMethodvalidatedSetFalse
(reason string, err error)
internal/controller/drpolicy_controller.go:456
↓ 6 callersMethodveleroNamespaceName
()
internal/controller/vrg_kubeobjects.go:961
↓ 6 callersFunctionverifyDRPCOwnedByPlacement
(placementObj client.Object, drpc *rmn.DRPlacementControl)
internal/controller/drplacementcontrol_controller_test.go:1750
↓ 6 callersFunctionverifyInitialDRPCDeployment
nolint:unparam
internal/controller/drplacementcontrol_controller_test.go:1609
↓ 6 callersFunctionverifyRDSpecAfterActionSwitch
(primaryCluster, secondaryCluster string, numOfRDSpecs int)
internal/controller/drplacementcontrol_controller_test.go:2898
↓ 6 callersFunctionwaitForGlobalDRPCPhase
(namespace string, expected rmn.DRState)
internal/controller/drplacementcontrol_global_test.go:250
↓ 6 callersMethodwith_exception
Return a new error preserving the traceback from another exception.
test/drenv/commands.py:46
↓ 5 callersMethodAssignRDAndRSAsOwnerToProtectedPVC
( obj client.Object, protectedPVC ramendrv1alpha1.ProtectedPVC, )
internal/controller/volsync/vshandler.go:342
↓ 5 callersMethodCheckReplicationSourceForRestoredPVCsCompleted
( ctx context.Context, replicationSources []*corev1.ObjectReference, )
internal/controller/cephfscg/volumegroupsourcehandler.go:54
↓ 5 callersMethodCreateOrUpdateVRGManifestWork
( name, namespace, homeCluster string, vrg rmn.VolumeReplicationGroup, annotations map[string]string, )
internal/controller/util/mw_util.go:130
↓ 5 callersMethodDeleteManagedClusterView
(clusterName, mcvName string, logger logr.Logger)
internal/controller/util/mcv_util.go:669
↓ 5 callersFunctionDeployVolSyncToCluster
Function to deploy Volsync from ACM to managed cluster via a ManagedClusterAddOn Calling this function requires a clusterrole that can create/update
internal/controller/volsync/deploy_volsync.go:32
↓ 5 callersFunctionDownloadTypedObjects
DownloadTypedObjects downloads all objects of the given type that have the given key prefix followed by the given object's type keyInfix. - Example ke
internal/controller/s3utils.go:520
↓ 5 callersMethodEnsurePVCfromRD
(rdSpec ramendrv1alpha1.VolSyncReplicationDestinationSpec, failoverAction bool, )
internal/controller/volsync/vshandler.go:1974
↓ 5 callersMethodExecute
(log logr.Logger)
internal/controller/hooks/check_hook.go:30
↓ 5 callersMethodFindManifestWork
(mwName, managedCluster string)
internal/controller/util/mw_util.go:87
↓ 5 callersFunctionGetAllDRPolicies
(ctx context.Context, client client.Reader)
internal/controller/util/drpolicy_util.go:66
↓ 5 callersMethodGetCluster
GetCluster returns the cluster from the env that matches clusterName. If not found, it returns an empty Cluster and an error.
e2e/types/env.go:10
↓ 5 callersFunctionGetHookExecutor
Based on the hook type, return the appropriate implementation of the hook.
internal/controller/hooks/hooks_factory.go:33
↓ 5 callersFunctionGetRD
(ctx context.Context, k8sClient client.Client, name, namespace string, log logr.Logger, )
internal/controller/volsync/vshandler.go:3106
↓ 5 callersMethodGetVRGFromManagedCluster
( resourceName, resourceNamespace, managedCluster string, annotations map[string]string)
internal/controller/util/mcv_util.go:38
↓ 5 callersMethodGetVolumeSnapshotClassFromPVCStorageClass
(storageClassName *string)
internal/controller/volsync/vshandler.go:2404
↓ 5 callersMethodGetVolumeSnapshotClasses
()
internal/controller/volsync/vshandler.go:2473
↓ 5 callersFunctionGetVolumeSnapshotsOwnedByVolumeGroupSnapshot
( ctx context.Context, k8sClient client.Client, vgs *groupsnapv1beta1.VolumeGroupSnapshot, logger logr.Log
internal/controller/util/cephfs_cg.go:312
↓ 5 callersFunctionIsCGEnabledForVolSync
IsCGEnabledForVolSync determines whether consistency group (CG) protection is enabled for CephFS volumes. It checks whether the VolumeGroupSnapshot CR
internal/controller/util/misc.go:388
↓ 5 callersMethodIsDRActionInProgress
()
internal/controller/volumereplicationgroup_controller.go:2613
↓ 5 callersMethodIsDiscovered
IsDiscovered returns true for OCM discovered application, false for OCM managed applications.
e2e/types/types.go:53
↓ 5 callersFunctionIsPodOwnedByRS
Helper functions used by multiple listers IsPodOwnedByRS checks if a pod is owned by the specified ReplicaSet and is running.
internal/controller/hooks/exec_hook.go:245
↓ 5 callersFunctionIsRSOwnedByDeployment
IsRSOwnedByDeployment checks if a ReplicaSet is owned by the specified Deployment and has ready replicas.
internal/controller/hooks/exec_hook.go:256
↓ 5 callersFunctionIsSubmarinerEnabled
(annotations map[string]string)
internal/controller/util/misc.go:392
↓ 5 callersMethodIsSubmarinerEnabled
()
internal/controller/volsync/vshandler.go:3415
↓ 5 callersMethodKustomize
Can differ based on the workload, hence part of the Workload interface
e2e/types/types.go:71
↓ 5 callersFunctionReportIfNotPresent
ReportIfNotPresent will report event if lastReportedEvent is not the same in last 10 minutes TODO: The duration 10 minutes can be changed to some othe
internal/controller/util/events.go:120
↓ 5 callersFunctionSecretFinalizer
(format TargetSecretFormat)
internal/controller/util/secrets_util.go:120
↓ 5 callersFunctionVSInRGD
(vs vsv1.VolumeSnapshot, rgd *ramendrv1alpha1.ReplicationGroupDestination)
internal/controller/util/cephfs_cg.go:257
↓ 5 callersFunctionVolumeGroupSnapshotClassMatchStorageProviders
( volumeGroupSnapshotClass groupsnapv1beta1.VolumeGroupSnapshotClass, storageClassProviders []string, )
internal/controller/util/cephfs_cg.go:176
↓ 5 callersFunction_chart_title
Convert chart name to human-readable title.
test/drenv/stress/plot.py:232
↓ 5 callersFunction_load_testdata
(name)
test/drenv/providers/minikube/networkextension_test.py:81
↓ 5 callersFunction_run
(command, *args, profile=None, output=None)
test/drenv/providers/minikube/__init__.py:471
↓ 5 callersMethodautoResync
autoResync determines if automatic resynchronization should be enabled for VolumeReplication. It returns true when: - The replication state is Seconda
internal/controller/vrg_volrep.go:1436
↓ 5 callersFunctionclearFakeUserPlacementRuleStatus
nolint:unparam
internal/controller/drplacementcontrol_controller_test.go:675
↓ 5 callersFunctioncreateDRClustersAsync
()
internal/controller/drplacementcontrol_controller_test.go:787
↓ 5 callersFunctioncreateDummyPVCAndMountingPod
nolint:funlen
internal/controller/volsync/vshandler_test.go:2035
↓ 5 callersFunctioncreateGlobalVRG
(name, namespace string, peerClasses []ramendrv1alpha1.PeerClass)
internal/controller/vrg_volgrouprep_global_test.go:317
↓ 5 callersFunctioncreatePlacementRule
(name, namespace string)
internal/controller/drplacementcontrol_controller_test.go:500
↓ 5 callersFunctioncreateSnapshot
(snapshotName, namespace string)
internal/controller/volsync/vshandler_test.go:1977
← previousnext →201–300 of 3,442, ranked by callers