anomaly

Documentation

Index

• func CreateAnomalyDiskSync(process *lib.Process, storage *lib.Storage, timeClock float64, ...)
• func CreateAnomalyHostAsync(process *lib.Process, host *lib.Host, timeEnd float64, newState float64)
• func CreateAnomalyHostSync(process *lib.Process, host *lib.Host, timeEnd float64, newState float64)
• func CreateAnomalyLinkAsync(process *lib.Process, link *lib.Link, timeClock float64, newState float64)
• func CreateAnomalyLinkSync(process *lib.Process, linkId *lib.Link, timeClock float64, newState float64)
• func CreateDiskAnomalyAsync(process *lib.Process, storage *lib.Storage, timeClock float64, ...)
• func CreateDiskAnomalyFullOFF(process *lib.Process, timeClock float64, storage *lib.Storage, ...)
• func LinkBreakAndRepair(kwargs map[string]interface{})
• func RepairHostAsync(process *lib.Process, host *lib.Host, timeEnd float64)
• func RepairHostSync(process *lib.Process, host *lib.Host, timeEnd float64)
• func RepairLinkAsync(process *lib.Process, link *lib.Link, timeClock float64)
• func RepairLinkSync(process *lib.Process, link *lib.Link, timeClock float64, newState float64)
• func ServerBreakAndRepair(kwargs map[string]interface{})
• func Vesnin1Anomaly(kwargs map[string]interface{})
• func Vesnin1ClientLinkDegradation(kwargs map[string]interface{})
• func Vesnin2Anomaly(kwargs map[string]interface{})
• func Vesnin2ClientLinkDegradation(kwargs map[string]interface{})
• type Anomaly
  • func NewAnomaly(resource lib.Resource, newState float64) (e *Anomaly)
• type AnomalyCollection
• type AnomalyManager
  • func NewAnomalyManager() *AnomalyManager
  • func (AM *AnomalyManager) AnomalyManagerProcess(TP *lib.Process, data interface{})
• type AnomalyType
• type ComponentStatus

Functions

func CreateAnomalyDiskSync

func CreateAnomalyDiskSync(process *lib.Process, storage *lib.Storage, timeClock float64, anomalyPart float64)

func (process *lib.Process) CreateAnomalyDiskSync(storage *lib.Storage, timeClock float64, anomalyPart float64) {

func CreateAnomalyHostAsync

func CreateAnomalyHostAsync(process *lib.Process, host *lib.Host, timeEnd float64, newState float64)

func CreateAnomalyHostSync

func CreateAnomalyHostSync(process *lib.Process, host *lib.Host, timeEnd float64, newState float64)

func CreateAnomalyLinkAsync

func CreateAnomalyLinkAsync(process *lib.Process, link *lib.Link, timeClock float64, newState float64)

func CreateAnomalyLinkSync

func CreateAnomalyLinkSync(process *lib.Process, linkId *lib.Link, timeClock float64, newState float64)

func CreateDiskAnomalyAsync

func CreateDiskAnomalyAsync(process *lib.Process, storage *lib.Storage, timeClock float64, anomalyPart float64)

func CreateDiskAnomalyFullOFF

func CreateDiskAnomalyFullOFF(process *lib.Process, timeClock float64, storage *lib.Storage, anomalyPart float64)

func LinkBreakAndRepair

func LinkBreakAndRepair(kwargs map[string]interface{})

func RepairHostAsync

func RepairHostAsync(process *lib.Process, host *lib.Host, timeEnd float64)

func RepairHostSync

func RepairHostSync(process *lib.Process, host *lib.Host, timeEnd float64)

func RepairLinkAsync

func RepairLinkAsync(process *lib.Process, link *lib.Link, timeClock float64)

func RepairLinkSync

func RepairLinkSync(process *lib.Process, link *lib.Link, timeClock float64, newState float64)

func ServerBreakAndRepair

func ServerBreakAndRepair(kwargs map[string]interface{})

func Vesnin1Anomaly

func Vesnin1Anomaly(kwargs map[string]interface{})

func Vesnin1ClientLinkDegradation

func Vesnin1ClientLinkDegradation(kwargs map[string]interface{})

func Vesnin2Anomaly

func Vesnin2Anomaly(kwargs map[string]interface{})

func Vesnin2ClientLinkDegradation

func Vesnin2ClientLinkDegradation(kwargs map[string]interface{})

Types

type Anomaly

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

func NewAnomaly

func NewAnomaly(resource lib.Resource, newState float64) (e *Anomaly)

type AnomalyCollection

type AnomalyCollection map[string]map[string]*AnomalyType

type AnomalyManager

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

func NewAnomalyManager

func NewAnomalyManager() *AnomalyManager

func (*AnomalyManager) AnomalyManagerProcess

func (AM *AnomalyManager) AnomalyManagerProcess(TP *lib.Process, data interface{})

type AnomalyType

type AnomalyType struct {
	Create func(float64, string, float64) `json:"create"`
	Repair func(float64, string)          `json:"repair"`
}

type ComponentStatus

type ComponentStatus int

const (
	FAIL ComponentStatus = iota
	OK

	// TODO Not implemented
	OKK
	MISSED
	BAD
	LOST
	MANUAL_RECOVERY
	RECOVERING
	RECOVERED
	FAIL_RECOVERY
	REPLACED
	DELETING
	DELETED
)