src

type ClientManager struct {
	*lib.Host `json:"-"`

	Cap float64 `json:"cap"`
	// contains filtered or unexported fields
}

type CommonProps struct {
	Status  anomaly.ComponentStatus `json:"health"`
	DevTemp float64                 `json:"dev_temp"`
	Uptime  float64                 `json:"uptime"`
}

type Controller struct {
	*Mock
	*NamingProps
	*ControllerProps `json:"props"`
	*lib.Host        `json:"-"`
	*SANComponent    `json:"-"`
	// contains filtered or unexported fields
}

type ControllerProps struct {
	*CommonProps
	LastTime float64 `json:"-"`

	TrafficDif       float64 `json:"traffic"`
	TrafficCum       float64 `json:"-"`
	InputTrafficDif  float64 `json:"-"`
	OutputTrafficDif float64 `json:"-"`
	InputTrafficCum  float64 `json:"-"`
	OutputTrafficCum float64 `json:"-"`

	FlopsExecutedDiff float64 `json:"load"`
	FlopsExecutedCum  float64 `json:"-"`
}

type DiskState struct {
	Pool       string `json:"pool"`
	TotalSpace uint64 `json:"total_cap_MB"` // TODO
	UsedSpace  uint64 `json:"used_cap_MB"`  // TODO
	AllocMB    uint64 `json:"alloc_MB"`     // TODO
	LenMB      uint64 `json:"len_MB"`       // TODO
	Status     string `json:"status"`       // TODO
	State      string `json:"state"`        // TODO

	AvgReadSpeed  float64     `json:"r_KBps"` // TODO `json:"avg_read_speed"`
	AvgWriteSpeed float64     `json:"w_KBps"` // TODO `json:"avg_write_speed"`
	ReadOps       float64     `json:"r_ops"`
	WriteOps      float64     `json:"w_ops"`
	ReadAwaitMs   float64     `json:"r_await_ms"`
	WriteAwaitMs  float64     `json:"w_await_ms"`
	Crrm          float64     `json:"crrm"`     // TODO
	Rrqm          float64     `json:"rrqm"`     // TODO
	Wrqm          float64     `json:"wrqm"`     // TODO
	Avgrq_sz      float64     `json:"avgrq_sz"` // TODO NZ
	Avgqu_sz      float64     `json:"avgqu_sz"` // TODO NZ
	MBRead        float64     `json:"MB_read"`
	MBWrtn        float64     `json:"MB_wrtn"`
	IORead        [10]float64 `json:"blk_read"`
	IOWrite       [10]float64 `json:"blk_write"`

	// unnecessary
	Async   float64 `json:"async"`
	Crrq    float64 `json:"crrq"`
	AvgQsz  float64 `json:"avg_qsz"`
	SvctmMs float64 `json:"svctm_ms"`
}

type FileInfo struct {
	*lib.File
	// contains filtered or unexported fields
}

type FileMetric struct {
	// contains filtered or unexported fields
}

type IOBalancer struct {
	*NamingProps
	*IOBalancerProps `json:"props"`
	*lib.Host        `json:"-"`
	*SANComponent    `json:"-"`
	GlobalDiskState  *DiskState `json:"-"`

	Controllers []*Controller        `json:"-"`
	Jbods       []*SANJBODController `json:"-"`

	FailManager *AtmosphereFailManager `json:"-"`
	// contains filtered or unexported fields
}

type IOBalancerFManager struct {
	// contains filtered or unexported fields
}

type IOBalancerProps struct {
	*CommonProps
	ReadResponseRate        float64 `json:"read_response_rate"`
	WriteResponseRate       float64 `json:"write_response_rate"`
	ReadRequestsRate        float64 `json:"read_requests_rate"`
	WriteRequestsRate       float64 `json:"write_requests_rate"`
	ReadDataVolume          float64 `json:"read_data_volume"`
	WriteDataVolume         float64 `json:"write_data_volume"`
	ReadRequestProcessTime  float64 `json:"read_request_process_time"`
	WriteRequestProcessTime float64 `json:"write_request_process_time"`
	IoProcessingMethod      uint8   `json:"io_processing_method"`
	ReadCancelRate          float64 `json:"read_cancel_rate"`
	WriteCancelRate         float64 `json:"write_cancel_rate"`
	BlockSize               uint16  `json:"block_size"`
	IOProcessCnt            uint8   `json:"io_process_cnt"`
	ReadQueueLength         uint8   `json:"read_queue_length"`
	WriteQueueLength        uint8   `json:"write_queue_length"`
}

type LogJson struct {
	Timestamp         float64            `json:"timestamp"`
	Ambience          *AtmosphereControl `json:"ambience"`
	StorageComponents []TraceAble        `json:"storage_components"`
	StState           *DiskState         `json:"storage_state"`
}

type Master struct {
	*lib.Host
	// contains filtered or unexported fields
}

type Mock struct {
}

type NamingProps struct {
	Type  string `json:"type"`
	Name  string `json:"-"`
	ID    string `json:"id"`
	Owner string `json:"owner"`
}

type SAN struct {
	// contains filtered or unexported fields
}

type SANBFunction func(*SANProcess, interface{})

type SANBuilder interface {
	IOBalancer(*IOBalancer) SANBuilder
	Controllers([]*Controller) SANBuilder
	JbodControllers([]*SANJBODController) SANBuilder
	Client(*ClientManager) SANBuilder
	Tracer(*TracerManager) SANBuilder
	AtmosphereControl(*AtmosphereControlManager) SANBuilder
	Build() SHD
}

type SANComponent struct {
	// contains filtered or unexported fields
}

type SANDisk struct {
	*Mock
	*NamingProps
	*StorageProperties `json:"props"`
	*lib.Storage       `json:"-"`
	*SANComponent      `json:"-"`
	GlobalDiskState    *DiskState `json:"-"`
	// contains filtered or unexported fields
}

type SANJBODController struct {
	*lib.Host     `json:"-"`
	*NamingProps  `json:"-"`
	*CommonProps  `json:"-"`
	*SANComponent `json:"-"`
	// contains filtered or unexported fields
}

type SANLink struct {
	*Mock
	*NamingProps
	*lib.Link     `json:"-"`
	*SANComponent `json:"-"`
	// contains filtered or unexported fields
}

type SANProcess struct {
	*lib.Process
}

type SANVolume struct {
	*NamingProps
	*StorageProperties `json:"props"`
	*SANComponent      `json:"-"`
	// contains filtered or unexported fields
}

type SHD interface {
	Read()
	Write()
	Save()

	GetControllers() []*Controller
	GetClientManager() *ClientManager
	GetIoBalancer() *IOBalancer
	GetSANJBODControllers() []*SANJBODController

	GetJsonLog() *LogJson
	GetDeepControllerManager() *deepcontroller.Manager
}

type StorageProperties struct {
	*CommonProps
	RawCapacity       float64 `json:"cap_gb"`
	Type              string  `json:"type"`
	JBOD              string  `json:"jbod"`
	Pool              string  `json:"pool"`
	AvgReadSpeed      float64 `json:"-"` // `json:"avg_read_speed"`
	AvgWriteSpeed     float64 `json:"-"` // `json:"avg_write_speed"`
	DataInterfacesCnt uint16  `json:"-"` // `json:"data_interfaces_cnt"`
	UsedSpace         float64 `json:"-"` // `json:"used_space"`
	FreeSpace         float64 `json:"-"` // `json:"free_space"`
}

type TraceAble interface {
	ResetDiffValues()
}

type TracerManager struct {
	OutputFileWrite bool
	// contains filtered or unexported fields
}