Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/RamenDR/ramen
/ functions
Functions
3,442 in github.com/RamenDR/ramen
⨍
Functions
3,442
◇
Types & classes
274
↓ 940 callers
Method
Errorf
Errorf writes a formatted error message to the log and markd the test as failed.
e2e/test/testing.go:42
↓ 592 callers
Method
GetName
()
e2e/types/types.go:49
↓ 416 callers
Method
Error
()
internal/controller/kubeobjects/requests.go:154
↓ 407 callers
Method
Get
(i int)
internal/controller/kubeobjects/requests.go:32
↓ 302 callers
Method
Create
(event.CreateEvent)
internal/controller/util/predicates.go:40
↓ 215 callers
Method
Update
(ctx context.Context, client client.Client)
internal/controller/hooks/scale_hook.go:34
↓ 214 callers
Method
GetNamespace
GetNamespace return the namespace for the ramen resources, or empty string if not using a special namespace.
e2e/types/types.go:51
↓ 163 callers
Method
Delete
(event.DeleteEvent)
internal/controller/util/predicates.go:41
↓ 115 callers
Method
DeepCopyInto
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 callers
Method
GetAnnotations
()
internal/controller/hooks/scale_hook.go:31
↓ 100 callers
Method
Env
()
e2e/types/types.go:94
↓ 98 callers
Method
DeepCopy
DeepCopy is for copying the receiver, creating a new ClusterStatus.
internal/controller/util/secrets_util.go:248
↓ 83 callers
Function
AddLabel
(obj client.Object, key, value string)
internal/controller/util/misc.go:166
↓ 76 callers
Method
Status
(logr.Logger)
internal/controller/kubeobjects/requests.go:26
↓ 67 callers
Function
objectConditionExpectEventually
( apiReader client.Reader, obj client.Object, status metav1.ConditionStatus, reasonMatcher, messageMatche
internal/controller/controllers_utils_test.go:179
↓ 61 callers
Method
Logger
()
e2e/types/types.go:93
↓ 53 callers
Method
AppNamespace
Namespace for application resources on the managed clusters.
e2e/types/types.go:112
↓ 53 callers
Method
Equal
Equal return true if config is equal to other config. nolint:cyclop
e2e/config/config.go:507
↓ 51 callers
Method
Context
()
e2e/types/types.go:96
↓ 47 callers
Function
SetStatusCondition
(existingConditions *[]metav1.Condition, newCondition metav1.Condition)
internal/controller/util/conditions.go:215
↓ 42 callers
Method
Fatalf
Fatalf writes a formatted error message to the log and fail the text immediately.
e2e/test/testing.go:54
↓ 40 callers
Function
addOrUpdateCondition
(conditions *[]metav1.Condition, conditionType string, observedGeneration int64, status metav1.ConditionStatu
internal/controller/drplacementcontrol_controller.go:2284
↓ 40 callers
Method
updatePVCDataReadyCondition
(pvcNamespace, pvcName, reason, message string)
internal/controller/vrg_volrep.go:2139
↓ 36 callers
Method
setProgression
* 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 callers
Method
Workload
()
e2e/types/types.go:104
↓ 34 callers
Method
ManagementNamespace
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 callers
Method
Config
()
e2e/types/types.go:95
↓ 29 callers
Method
Name
()
e2e/types/types.go:105
↓ 28 callers
Function
GetVolSyncPSKSecretNameFromVRGName
(vrgName string)
internal/controller/volsync/secret_propagator.go:25
↓ 27 callers
Method
AddLabel
(key, value string)
internal/controller/util/misc.go:70
↓ 27 callers
Function
genStorageIDLabel
(storageID string)
internal/controller/vrg_volrep_test.go:3664
↓ 26 callers
Function
ensureClassStatus
(apiReader client.Reader, drCConfig *ramen.DRClusterConfig, classes Classes, )
internal/controller/drclusterconfig_controller_test.go:67
↓ 26 callers
Function
genVRCLabels
nolint:unparam
internal/controller/vrg_volrep_test.go:3687
↓ 25 callers
Function
getManifestWorkCount
(homeClusterNamespace string)
internal/controller/drplacementcontrol_controller_test.go:1112
↓ 25 callers
Method
verifyVRGStatusExpectation
(expectedStatus bool, reason string)
internal/controller/vrg_volrep_test.go:2476
↓ 24 callers
Function
AddAnnotation
(obj client.Object, key, value string)
internal/controller/util/misc.go:261
↓ 24 callers
Method
requeue
()
internal/controller/volumereplicationgroup_controller.go:620
↓ 24 callers
Method
waitForVRCountToMatch
(vrCount int)
internal/controller/vrg_volrep_test.go:3020
↓ 23 callers
Method
GetAppName
()
e2e/types/types.go:74
↓ 23 callers
Function
NewVSHandler
(ctx context.Context, client client.Client, log logr.Logger, owner metav1.Object, asyncSpec *ramendrv1alpha1.
internal/controller/volsync/vshandler.go:94
↓ 23 callers
Function
updateDRClusterManifestWorkStatus
(k8sClient client.Client, apiReader client.Reader, clusterNamespace string)
internal/controller/controllers_utils_test.go:113
↓ 22 callers
Method
Error
Error writes an error message to the log and mark the test as failed.
e2e/test/testing.go:36
↓ 22 callers
Function
RamenOperatorNamespace
()
internal/controller/ramenconfig.go:455
↓ 22 callers
Function
delete
Run kubectl delete ... logging progress messages.
test/drenv/kubectl.py:137
↓ 22 callers
Function
getLatestDRPC
(namespace string)
internal/controller/drplacementcontrol_controller_test.go:643
↓ 22 callers
Function
makeDRPCWithLabel
(name, namespace, vgrLabel string, action rmn.DRAction, failover, preferred string, )
internal/controller/drpc_predicate_test.go:501
↓ 21 callers
Function
ResourceIsDeleted
Return true if resource was marked for deletion.
internal/controller/util/objectmeta.go:26
↓ 21 callers
Method
getVRG
()
internal/controller/vrg_volrep_test.go:2441
↓ 21 callers
Function
newVRGTestCaseCreateAndStart
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 callers
Method
EnsureConfigMap
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 callers
Function
NewExcludedResourcesManager
NewExcludedResourcesManager creates a new ExcludedResourcesManager
internal/controller/kubeobjects/velero/exclude_resources.go:72
↓ 19 callers
Function
updateDRClusterConfigMWStatus
(k8sClient client.Client, apiReader client.Reader, clusterNamespace string)
internal/controller/controllers_utils_test.go:122
↓ 18 callers
Function
NewResourceUpdater
(obj client.Object)
internal/controller/util/misc.go:62
↓ 18 callers
Method
SetAnnotations
(map[string]string)
internal/controller/hooks/scale_hook.go:32
↓ 18 callers
Function
updateDRClusterParameters
(drc *ramen.DRCluster)
internal/controller/controllers_utils_test.go:91
↓ 17 callers
Function
BuildManagedClusterViewName
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 callers
Function
ConvertCommandToStringArray
(command string)
internal/controller/hooks/exec_hook.go:313
↓ 17 callers
Function
NewVSCGHandler
( ctx context.Context, k8sClient client.Client, instance *ramendrv1alpha1.VolumeReplicationGroup, volumeGr
internal/controller/cephfscg/cghandler.go:27
↓ 17 callers
Function
add_command
(sp, name, func, help=None, envfile=True)
test/drenv/__main__.py:248
↓ 17 callers
Method
getConditionStatusForTypeAvailable
()
internal/controller/drplacementcontrol.go:3151
↓ 17 callers
Function
getHookSpec
(resourceType, condition string)
internal/controller/hooks/check_hook_test.go:255
↓ 17 callers
Function
setupFakeClient
setupFakeClient creates a fake client with corev1 scheme
internal/controller/kubeobjects/velero/exclude_resources_test.go:30
↓ 17 callers
Function
waitForCompletion
(expectedState string)
internal/controller/drplacementcontrol_controller_test.go:1339
↓ 16 callers
Method
AddSecretToCluster
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 callers
Method
DeleteObjectsWithKeyPrefix
(keyPrefix string)
internal/controller/s3utils.go:99
↓ 16 callers
Function
HavePVCName
HavePVCName returns a matcher that expects the PVC to have the given name.
internal/controller/util/pvcs_util_test.go:262
↓ 16 callers
Method
SetupWithManager
SetupWithManager sets up the controller with the Manager.
internal/controller/drpolicy_controller.go:498
↓ 16 callers
Function
checkTimestampStream
(t *testing.T, got string, want ...string)
test/timestamp/main_test.go:163
↓ 16 callers
Function
populateDRClusters
()
internal/controller/drplacementcontrol_controller_test.go:733
↓ 16 callers
Function
run
(*args, stdin=None, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
test/drenv/commands_test.py:737
↓ 15 callers
Function
FindCondition
(existingConditions []metav1.Condition, conditionType string)
internal/controller/util/conditions.go:254
↓ 15 callers
Function
IsDiffSyncEnabled
IsDiffSyncEnabled checks if the enable-diff annotation is set to true on the resource
internal/controller/util/misc.go:419
↓ 15 callers
Function
deleteDRPC
()
internal/controller/drplacementcontrol_controller_test.go:591
↓ 15 callers
Method
getLastDRState
()
internal/controller/drplacementcontrol.go:3193
↓ 15 callers
Method
s3KeyPrefix
()
internal/controller/vrg_volrep_test.go:2037
↓ 15 callers
Function
vrgGet
(vrgNamespacedName types.NamespacedName)
internal/controller/vrg_volrep_test.go:2457
↓ 14 callers
Method
ObjectStore
ObjectStore returns an object that satisfies ObjectStorer interface
internal/controller/s3utils.go:88
↓ 14 callers
Method
vrgNamespacedName
()
internal/controller/vrg_volrep_test.go:2033
↓ 13 callers
Method
AddAnnotation
(key, value string)
internal/controller/util/misc.go:93
↓ 13 callers
Method
CreateOrUpdateVolumeGroupSnapshot
( ctx context.Context, owner metav1.Object, )
internal/controller/cephfscg/volumegroupsourcehandler.go:37
↓ 13 callers
Method
Object
()
internal/controller/kubeobjects/requests.go:22
↓ 13 callers
Function
OwnerLabels
(owner metav1.Object)
internal/controller/util/labels.go:58
↓ 13 callers
Method
ReconcileRS
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 callers
Method
RemoveFinalizer
(finalizerName string)
internal/controller/util/misc.go:146
↓ 13 callers
Method
getPVC
(pvcNamespacedName types.NamespacedName)
internal/controller/volsync/vshandler.go:1339
↓ 13 callers
Function
info
(fmt, *args)
test/drenv/test.py:89
↓ 13 callers
Function
setDRPCSpecExpectationTo
(namespace, preferredCluster, failoverCluster string, action rmn.DRAction)
internal/controller/drplacementcontrol_controller_test.go:615
↓ 13 callers
Method
setDRState
(nextState rmn.DRState)
internal/controller/drplacementcontrol.go:2946
↓ 12 callers
Function
DRPolicyClusterNames
(drpolicy *rmn.DRPolicy)
internal/controller/util/drpolicy_util.go:22
↓ 12 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Sync.
api/v1alpha1/zz_generated.deepcopy.go:1513
↓ 12 callers
Method
DeepCopyInto
DeepCopyInto is for copying the receiver, writing into out. in must be non-nil.
internal/controller/util/secrets_util.go:261
↓ 12 callers
Method
Fatal
Fatal writes an error message to the log and fail the text immediately.
e2e/test/testing.go:48
↓ 12 callers
Function
GetLocalReplicationName
(pvcName string)
internal/controller/util/misc.go:491
↓ 12 callers
Function
GetReplicationDestinationName
(pvcName string)
internal/controller/util/misc.go:487
↓ 12 callers
Method
Is
Called by errors.Is() to match target.
internal/controller/kubeobjects/requests.go:157
↓ 12 callers
Function
WithLog
WithLog returns a t wrapped with a specified log. nolint:thelper
e2e/test/testing.go:21
↓ 12 callers
Function
createConfigMapWithJSON
createConfigMapWithJSON creates a ConfigMap with JSON-formatted excluded resources
internal/controller/kubeobjects/velero/exclude_resources_test.go:41
↓ 12 callers
Method
getResourceFromManagedCluster
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 callers
Method
promoteVolReps
()
internal/controller/vrg_volrep_test.go:3130
↓ 12 callers
Method
updatePVCDataProtectedCondition
(pvcNamespace, pvcName, reason, message string)
internal/controller/vrg_volrep.go:2148
next →
1–100 of 3,442, ranked by callers