package ceph_recovery

import "gitee.com/liucxer/ceph-tools/pkg/interfacer"

type RecoveryPool struct {
	RecoveryVolume string `json:"recoveryVolume"`
	RecoveryPool   string `json:"recoveryPool"`
}

func (pool *RecoveryPool) StartRecovery(worker interfacer.Worker) error {
	_, err := worker.ExecCmd("ceph osd pool set " + pool.RecoveryPool + " size 2")
	return err
}

func (pool *RecoveryPool) StopRecovery(worker interfacer.Worker) error {
	_, err := worker.ExecCmd("ceph osd pool set " + pool.RecoveryPool + " size 1")
	return err
}