anomaly

package

v0.0.0-...-8d05fb3 Latest Latest Go to latest Published: Oct 4, 2019 License: GPL-3.0 Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/hse-lambda/sango

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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
)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL