controller

Jun 25, 2025

Changes in this version

+ const ReplicationSourceToSourcePVCIndex

+ const VolPopCRName

+ const VolPopPVCToReplicationDestinationIndex

+ const VolPopPVCToStorageClassIndex

+ func EnsureVolSyncVolumePopulatorCRIfCRDPresent(ctx context.Context, k8sClient client.Client, logger logr.Logger) error

+ func GetVolumePopulatorPVCPrime(ctx context.Context, c client.Client, pvc *corev1.PersistentVolumeClaim) (*corev1.PersistentVolumeClaim, error)

+ func IndexFieldsForReplicationSource(ctx context.Context, fieldIndexer client.FieldIndexer) error

+ func IndexFieldsForVolumePopulator(ctx context.Context, fieldIndexer client.FieldIndexer) error

+ type ReplicationDestinationReconciler struct

+ EventRecorder record.EventRecorder

+ Log logr.Logger

+ Scheme *runtime.Scheme

+ func (r *ReplicationDestinationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *ReplicationDestinationReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type ReplicationSourceReconciler struct

+ EventRecorder record.EventRecorder

+ Log logr.Logger

+ Scheme *runtime.Scheme

+ func (r *ReplicationSourceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *ReplicationSourceReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type VolumePopulatorReconciler struct

+ EventRecorder record.EventRecorder

+ Log logr.Logger

+ Scheme *runtime.Scheme

+ func (r *VolumePopulatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *VolumePopulatorReconciler) SetupWithManager(mgr ctrl.Manager) error