ceph_cluster

Documentation

Index

• type CephCluster
  • func NewCluster(ipAddr string) (*CephCluster, error)
  • func (cluster *CephCluster) BackupAndClearCephLog() error
  • func (cluster *CephCluster) CephStatus(second int) (*CephStatusList, error)
  • func (cluster *CephCluster) ClearCephLog() error
  • func (cluster *CephCluster) ClearOsdLog(osdNums []int64) error
  • func (cluster *CephCluster) Close() error
  • func (cluster *CephCluster) CollectCephLog(dstDir string) error
  • func (cluster *CephCluster) CollectOsdLog(dstDir string, osdNums []int64) error
  • func (cluster *CephCluster) CurrentCephStatus() (*CephStatus, error)
  • func (cluster *CephCluster) ExecCmd(cmd string) error
  • func (cluster *CephCluster) OsdStatus(osdNum int64) (*OSDStatus, error)
• type CephHealth
• type CephStatus
• type CephStatusList
  • func (l CephStatusList) AvgCephStatus() CephStatus
  • func (l CephStatusList) AvgReadBytesSec() float64
  • func (l CephStatusList) AvgReadOpPerSec() float64
  • func (l CephStatusList) AvgRecoveringBytesPerSec() float64
  • func (l CephStatusList) AvgWriteBytesSec() float64
  • func (l CephStatusList) AvgWriteOpPerSec() float64
  • func (l CephStatusList) RecoveryDistribution() []int
  • func (l *CephStatusList) SaveCSV(filePath string) error
• type OSDStatus

Types

type CephCluster

type CephCluster struct {
	IpAddr  string `json:"ipAddr"`
	Master  *host_client.HostClient
	Clients []*host_client.HostClient
	// contains filtered or unexported fields
}

func NewCluster

func NewCluster(ipAddr string) (*CephCluster, error)

func (*CephCluster) BackupAndClearCephLog

func (cluster *CephCluster) BackupAndClearCephLog() error

func (*CephCluster) CephStatus

func (cluster *CephCluster) CephStatus(second int) (*CephStatusList, error)

func (*CephCluster) ClearCephLog

func (cluster *CephCluster) ClearCephLog() error

func (*CephCluster) ClearOsdLog

func (cluster *CephCluster) ClearOsdLog(osdNums []int64) error

func (*CephCluster) Close

func (cluster *CephCluster) Close() error

func (*CephCluster) CollectCephLog

func (cluster *CephCluster) CollectCephLog(dstDir string) error

func (*CephCluster) CollectOsdLog

func (cluster *CephCluster) CollectOsdLog(dstDir string, osdNums []int64) error

func (*CephCluster) CurrentCephStatus

func (cluster *CephCluster) CurrentCephStatus() (*CephStatus, error)

func (*CephCluster) ExecCmd

func (cluster *CephCluster) ExecCmd(cmd string) error

func (*CephCluster) OsdStatus

func (cluster *CephCluster) OsdStatus(osdNum int64) (*OSDStatus, error)

type CephHealth

type CephHealth struct {
	Status string                 `json:"status"`
	Checks map[string]interface{} `json:"checks"`
}

type CephStatus

type CephStatus struct {
	CephHealth
	ReadBytesSec          float64 `json:"read_bytes_sec"`
	ReadOpPerSec          float64 `json:"read_op_per_sec"`
	RecoveringBytesPerSec float64 `json:"recovering_bytes_per_sec"`
	WriteBytesSec         float64 `json:"write_bytes_sec"`
	WriteOpPerSec         float64 `json:"write_op_per_sec"`
}

type CephStatusList

type CephStatusList []CephStatus

func (CephStatusList) AvgCephStatus

func (l CephStatusList) AvgCephStatus() CephStatus

func (CephStatusList) AvgReadBytesSec

func (l CephStatusList) AvgReadBytesSec() float64

func (CephStatusList) AvgReadOpPerSec

func (l CephStatusList) AvgReadOpPerSec() float64

func (CephStatusList) AvgRecoveringBytesPerSec

func (l CephStatusList) AvgRecoveringBytesPerSec() float64

func (CephStatusList) AvgWriteBytesSec

func (l CephStatusList) AvgWriteBytesSec() float64

func (CephStatusList) AvgWriteOpPerSec

func (l CephStatusList) AvgWriteOpPerSec() float64

func (CephStatusList) RecoveryDistribution

func (l CephStatusList) RecoveryDistribution() []int

func (*CephStatusList) SaveCSV

func (l *CephStatusList) SaveCSV(filePath string) error

type OSDStatus

type OSDStatus struct {
	ActiveClean bool `json:"activeClean"`
}