deepcontroller

package
v0.0.0-...-8d05fb3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 4, 2019 License: GPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Component

type Component struct {
	Type          string                `json:"type"`
	Name          string                `json:"name"`
	State         *ComponentAnomaly     `json:"state"`
	Parameters    map[string]float64    `json:"parameters"`
	SubComponents map[string]*Component `json:"subcomponents"`
}

type ComponentAnomaly

type ComponentAnomaly struct {
	Anomaly string  `json:"anomaly"`
	Degree  float64 `json:"degree"`
}

type DCAble

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

	GetCurrentState() string
	SetCurrentState(string)
}

type DeepLoad

type DeepLoad struct {
	Name      string  `json:"name"`
	BlockSize string  `json:"blocksize"`
	Size      float64 `json:"size"`
	Time      float64 `json:"time"`
	Type      string  `json:"type"`
	NumJobs   int     `json:"num_jobs"`
}

type DeepParameters

type DeepParameters struct {
	Name       string                `json:"name"`
	Type       string                `json:"type"`
	Action     *int                  `json:"action"`
	Load       []*DeepLoad           `json:"load"`
	Components map[string]*Component `json:"subcomponents"`
}

type Manager

type Manager struct {
	DeepControllingMode bool
	// contains filtered or unexported fields
}

func Init_d

func Init_d(flags *lib.DeepControllerFlags) *Manager

func NewManager

func NewManager(flags *lib.DeepControllerFlags) *Manager

func (*Manager) AnomalyCreatorRecursiveDC

func (DCM *Manager) AnomalyCreatorRecursiveDC(TP *lib.Process, components map[string]*Component)

func (*Manager) Close

func (DCM *Manager) Close()

func (*Manager) CommunicateWithDC

func (DCM *Manager) CommunicateWithDC(jsonBytes []byte) *DeepParameters

func (*Manager) CreateAnomaly

func (DCM *Manager) CreateAnomaly(P *lib.Process, params *ComponentAnomaly,
	component lib.DCAble, cTime float64)

func (*Manager) CreateDeepControllerImpact

func (DCM *Manager) CreateDeepControllerImpact(TP *lib.Process, newParams *DeepParameters)

func (*Manager) DeepControllerManagerProcess

func (DCM *Manager) DeepControllerManagerProcess(TP *lib.Process, data interface{})

func (*Manager) ParametersUpdaterRecursiveDC

func (DCM *Manager) ParametersUpdaterRecursiveDC(components map[string]*Component)

type ZMQReqSocket

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

func NewZMQReqSocket

func NewZMQReqSocket(protocol string, host string, port string) *ZMQReqSocket

Jump to

Keyboard shortcuts

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