exec_config

Documentation

Index

• type ExecConfig
  • func NewExecConfig(configPath string) (*ExecConfig, error)
  • func (execConfig *ExecConfig) CephStatus(result *ExecResult) error
  • func (execConfig *ExecConfig) JobCost(result *ExecResult) error
  • func (execConfig *ExecConfig) OutputCephStatus(cephStatusList ceph_cluster.CephStatusList, fileName string) error
  • func (execConfig *ExecConfig) OutputOneJobExecResult(res ExecResult) error
  • func (execConfig *ExecConfig) OutputRecoveryConfig(list ceph.OsdRecoveryConfigList, fileName string) error
  • func (execConfig *ExecConfig) ReadConfig(configFilePath string) error
  • func (execConfig *ExecConfig) RecoveryConfig(result *ExecResult) error
  • func (execConfig *ExecConfig) Run() (*[]ExecResult, error)
  • func (execConfig *ExecConfig) RunOneJob(fioConfig *FioConfig, testBaseLine bool) (*ExecResult, error)
  • func (execConfig *ExecConfig) WaitOsdClean() error
• type ExecResult
  • func (res *ExecResult) SetCephStatus(cephStatus ceph_cluster.CephStatus)
  • func (res *ExecResult) SetJobCost(jobCostList ceph.JobCostList)
  • func (res *ExecResult) SetRecoveryConfig(conf ceph.OsdRecoveryConfig)
• type FioConfig
  • func (fioConfig FioConfig) FileName() string

Types

type ExecConfig

type ExecConfig struct {
	*ceph_cluster.CephCluster
	*ceph.CephConf

	WithRecovery bool `json:"withRecovery"`
	ceph_recovery.RecoveryPool

	WithMaxActive bool    `json:"withMaxActive"`
	MaxActive     []int64 `json:"maxActive"`

	WithRecoverySleep bool      `json:"withRecoverySleep"`
	RecoverySleep     []float64 `json:"recoverySleep"`

	ThreadNums  int64   `json:"threadNums"`
	WithJobCost bool    `json:"withJobCost"`
	OsdNum      []int64 `json:"osdNum"`

	WithCephStatus bool `json:"withCephStatus"`

	BlockSize []blockSizeItem `json:"blockSize"`

	DiskType   string `json:"diskType"`
	IpAddr     string `json:"ipAddr"`
	Runtime    int64  `json:"runtime"`
	DataPool   string `json:"dataPool"`
	DataVolume string `json:"dataVolume"`
	ResultDir  string `json:"resultDir"`
}

func NewExecConfig

func NewExecConfig(configPath string) (*ExecConfig, error)

func (*ExecConfig) CephStatus

func (execConfig *ExecConfig) CephStatus(result *ExecResult) error

func (*ExecConfig) JobCost

func (execConfig *ExecConfig) JobCost(result *ExecResult) error

func (*ExecConfig) OutputCephStatus

func (execConfig *ExecConfig) OutputCephStatus(cephStatusList ceph_cluster.CephStatusList, fileName string) error

func (*ExecConfig) OutputOneJobExecResult

func (execConfig *ExecConfig) OutputOneJobExecResult(res ExecResult) error

func (*ExecConfig) OutputRecoveryConfig

func (execConfig *ExecConfig) OutputRecoveryConfig(list ceph.OsdRecoveryConfigList, fileName string) error

func (*ExecConfig) ReadConfig

func (execConfig *ExecConfig) ReadConfig(configFilePath string) error

func (*ExecConfig) RecoveryConfig

func (execConfig *ExecConfig) RecoveryConfig(result *ExecResult) error

func (*ExecConfig) Run

func (execConfig *ExecConfig) Run() (*[]ExecResult, error)

func (*ExecConfig) RunOneJob

func (execConfig *ExecConfig) RunOneJob(fioConfig *FioConfig, testBaseLine bool) (*ExecResult, error)

func (*ExecConfig) WaitOsdClean

func (execConfig *ExecConfig) WaitOsdClean() error

type ExecResult

type ExecResult struct {
	FioConfig
	fio.FioResult

	ceph_cluster.CephStatus

	ExpectCost         float64 `json:"expectCost"`
	ActualCost         float64 `json:"actualCost"`
	BaseLineActualCost float64 `json:"baseLineActualCost"`

	ceph.OsdRecoveryConfig
}

func (*ExecResult) SetCephStatus

func (res *ExecResult) SetCephStatus(cephStatus ceph_cluster.CephStatus)

func (*ExecResult) SetJobCost

func (res *ExecResult) SetJobCost(jobCostList ceph.JobCostList)

func (*ExecResult) SetRecoveryConfig

func (res *ExecResult) SetRecoveryConfig(conf ceph.OsdRecoveryConfig)

type FioConfig

type FioConfig struct {
	WithRecovery bool `json:"withRecovery"`
	ceph_recovery.RecoveryPool

	WithJobCost bool `json:"withJobCost"`

	DiskType      string  `json:"diskType"`
	Runtime       int64   `json:"runtime"`
	DataPool      string  `json:"dataPool"`
	DataVolume    string  `json:"dataVolume"`
	OpType        string  `json:"opType"`
	BlockSize     string  `json:"blockSize"`
	IoDepth       int64   `json:"ioDepth"`
	MaxActive     int64   `json:"maxActive"`
	NumJobs       int64   `json:"numJobs"`
	RecoverySleep float64 `json:"recoverySleep"`
}

func (FioConfig) FileName

func (fioConfig FioConfig) FileName() string