cpi

package

v1.0.0 Latest Latest Go to latest Published: Oct 13, 2021 License: Apache-2.0, BSD-3-Clause, MIT Imports: 14 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

This section is empty.

This section is empty.

func AddRecord(record CPIRecord)

AddRecord adds record to default CPIManager

func InitManager(cfg types.CPIManagerConfig) error

InitManager initializes default CPIManager

type Antagonist struct {
	TaskMeta
	// contains filtered or unexported fields
}

Antagonist describe antagonist tasks information

type CPIManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

CPIManager compares aggregated CPI data from prometheus and local CPI data to detect outliers and antagonists

func (m *CPIManager) AddRecord(record CPIRecord)

AddRecord caches record in CPIManager

type CPIRecord struct {
	TaskMeta
	CPI       float64
	CPUUsage  float64
	Timestamp time.Time
}

CPIRecord contains cpi and cpu data for a task

type JobSpec struct {
	JobName   string
	CPIMean   float64
	CPIStdDev float64
	ExpiredAt time.Time
}

JobSpec contains aggregated cpi data for a job

func (s JobSpec) String() string

String prints JobSpec

type TaskMeta struct {
	JobName  string
	TaskName string
}

TaskMeta describes tasks

func (t TaskMeta) String() string

String prints TaskMeta