package ceph_osd

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

type CephOsd struct {
	OsdID int64 `json:"OsdID"`
	interfacer.Worker
}

func NewCephOsd(osdID int64, worker interfacer.Worker) *CephOsd {
	osd := CephOsd{OsdID: osdID}
	osd.Worker = worker
	return &osd
}

func (osd *CephOsd) DropCache() error {
	var (
		err error
	)

	_, err = osd.ExecCmd("ceph tell osd." + strconv.Itoa(int(osd.OsdID)) + " cache drop")
	return err
}