Documentation
¶
Index ¶
- func GetCurrentReplicationState(instanceStatusState replicationv1alpha1.State) replicationv1alpha1.State
- func GetReplicationState(instanceState replicationv1alpha1.ReplicationState) replicationv1alpha1.State
- func WaitForVolumeReplicationResource(client client.Client, logger logr.Logger, resourceName string) error
- type VolumeGroupReplicationContentReconciler
- type VolumeGroupReplicationReconciler
- type VolumeReplicationReconciler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetCurrentReplicationState ¶ added in v0.13.0
func GetCurrentReplicationState(instanceStatusState replicationv1alpha1.State) replicationv1alpha1.State
func GetReplicationState ¶ added in v0.13.0
func GetReplicationState(instanceState replicationv1alpha1.ReplicationState) replicationv1alpha1.State
Types ¶
type VolumeGroupReplicationContentReconciler ¶
type VolumeGroupReplicationContentReconciler struct {
client.Client
Scheme *runtime.Scheme
// ConnectionPool consists of map of Connection objects
Connpool *conn.ConnectionPool
// Timeout for the Reconcile operation.
Timeout time.Duration
}
VolumeGroupReplicationContentReconciler reconciles a VolumeGroupReplicationContent object
func (*VolumeGroupReplicationContentReconciler) Reconcile ¶
func (r *VolumeGroupReplicationContentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
func (*VolumeGroupReplicationContentReconciler) SetupWithManager ¶
func (r *VolumeGroupReplicationContentReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type VolumeGroupReplicationReconciler ¶
type VolumeGroupReplicationReconciler struct {
client.Client
Scheme *runtime.Scheme
Recorder record.EventRecorder
MaxGroupPVCCount int
// contains filtered or unexported fields
}
VolumeGroupReplicationReconciler reconciles a VolumeGroupReplication object
func (*VolumeGroupReplicationReconciler) Reconcile ¶
func (r *VolumeGroupReplicationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
func (*VolumeGroupReplicationReconciler) SetupWithManager ¶
func (r *VolumeGroupReplicationReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type VolumeReplicationReconciler ¶
type VolumeReplicationReconciler struct {
client.Client
Scheme *runtime.Scheme
// ConnectionPool consists of map of Connection objects
Connpool *conn.ConnectionPool
// Timeout for the Reconcile operation.
Timeout time.Duration
Replication grpcClient.VolumeReplication
}
VolumeReplicationReconciler reconciles a VolumeReplication object.
func (*VolumeReplicationReconciler) Reconcile ¶
func (r *VolumeReplicationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.7.0/pkg/reconcile
func (*VolumeReplicationReconciler) SetupWithManager ¶
func (r *VolumeReplicationReconciler) SetupWithManager(mgr ctrl.Manager, ctrlOptions controller.Options) error
SetupWithManager sets up the controller with the Manager.
Source Files
Directories