lib

type AnomalyFlags struct {
	AnomalyType        string
	AnomalyAmount      int
	MinAnomalyTime     float64
	MaxAnomalyTime     float64
	MinAnomalyDuration float64
	MaxAnomalyDuration float64
	// contains filtered or unexported fields
}

type BLOCKSIZE float64

type BaseBehaviourFunction func(ProcessInterface, interface{})

type BlockParams struct {
	// Storage
	RateTime      *NormalParam `json:"rate_time"`
	SeekTime      *NormalParam `json:"seek_time"`
	OverheadsTime *NormalParam `json:"overheads_time"`
}

type ClientFlags struct {
	FileAmount   int
	MinFileSize  float64
	MaxFileSize  float64
	MinPauseTime float64
	MaxPauseTime float64
	RequestType  RequestType
	// contains filtered or unexported fields
}

type Closeable interface {
	Close()
}

type CommonPacketInfo struct {
	Size  float64 `json:"size"`
	Index int     `json:"-"`
	// Network
	TransmissionTime    *NormalParam `json:"transmission_time"`
	LatencyTime         *NormalParam `json:"latency_time"`
	ReadProcessingTime  *NormalParam `json:"read_processing_time"`
	WriteProcessingTime *NormalParam `json:"write_processing_time"`
	RecoveryTime        *NormalParam `json:"recovery_time"`

	RandReadParams  *BlockParams `json:"rand_read"`
	RandWriteParams *BlockParams `json:"rand_write"`
	SeqReadParams   *BlockParams `json:"seq_read"`
	SeqWriteParams  *BlockParams `json:"seq_write"`
	ReadWriteParams *BlockParams `json:"read_write"`
	// contains filtered or unexported fields
}

type ControllerParams struct {
	ProcessingTime *NormalParam `json:"processing_time"`
	RecoveryTime   *NormalParam `json:"recovery_time"`
}

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

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

type DCAble interface {
	Break(*Process, float64, float64)
	Repair(*Process, float64)
	Update(map[string]float64)
	Reset()

	GetCurrentState() string
	SetCurrentState(string)
}

type DeepControllerFlags struct {
	DeepControllingMode bool
	DeepHost            string
	DeepPort            string
	DeepProtocol        string
	DeepJsonDelay       float64

	SimRun float64
}

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

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

type EventQueue []*Event

type EventType int

type File struct {
	Size        float64
	Filename    string
	RequestType RequestType
	Packet1     *Packet
	Packet2     *Packet
	Latency     float64
	NumJobs     int
}

type Host struct {
	Name  string
	Type  string
	Id    string
	Speed float64
	// contains filtered or unexported fields
}

type JBOD struct {
	Name    string
	Disks   JBODDisks
	DiskArr map[int]*Storage
}

type JBODDisks []*Storage

type Link struct {
	Name      string
	Bandwidth float64
	Latency   float64
	State     float64

	Src, Dst *Host
	// contains filtered or unexported fields
}

type MachineInterface interface {
}

type NetworkPacket int

type NetworkParams struct {
	TransmissionTime *NormalParam `json:"transmission_time"`
	LatencyTime      *NormalParam `json:"latency_time"`
}

type NormalParam struct {
	Mean   float64 `json:"mean"`
	StdDev float64 `json:"std_dev"`
}

type Packet struct {
	Type  RequestType `json:"-"`
	Index int         `json:"-"`
	Size  float64     `json:"size"`

	NetworkTime *NetworkParams    `json:"transmission_time"`
	ContrTime   *ControllerParams `json:"recovery_time"`
	DiskParams  *BlockParams      `json:"disk_params"`
}

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

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

type ProcessInterface interface {
	SetParent(*Process)
	GetParent() *Process
}

type RequestType int

type Resource interface {
	Put(e *Event, globalQueue *globalEventQueue)
}

type STATUS int

type Storage struct {
	*StorageType
	Name string
	ID   string
	Type string

	JBOD      *JBOD
	BlockSize BLOCKSIZE
	ReadLink  *Link
	WriteLink *Link
	// contains filtered or unexported fields
}

type StoragePacket int

type StorageType struct {
	TypeId    string
	WriteRate float64
	ReadRate  float64
	Size      float64
}

type SystemFlags struct {
	PlatformFileName        string
	PacketFileName          string
	AtmControlFileName      string
	AtmDependenciesFileName string
	ClientFileName          string
	NumJobsFileName         string

	SimRun  float64
	NDisks  int
	NumJobs int

	WriteClientFlags *ClientFlags
	ReadClientFlags  *ClientFlags
	AnomalyFlags     *AnomalyFlags
	TracerFlags      *TracerFlags
	DCFlags          *DeepControllerFlags
}

type TracerFlags struct {
	OutputFileName string
}

type Volume struct {
	Id     string       `xml:"id,attr"`
	Mounts []VolumePart `xml:"mount"`
}

type VolumePart struct {
	XMLName xml.Name `xml:"mount"`
	Id      string   `xml:"id,attr"`
}