scenarios

Documentation

Index

• Constants
• func CleanupApp(appManager framework.AppManager, appInfo *framework.AppInfo, ...)
• func ConvertToRequestInfos(requestConfigs []*RequestConfig) []*framework.RequestInfo
• func LoadScenarioConf(conf *framework.Config, scenarioName string, scenarioConf interface{}) error
• func ParseTableFromQPSStatistics(statistics *profiling.QPSStatistics, orderedKeys []framework.TaskConditionType) *utils.Table
• func ParseTableFromStatistic(statistics *profiling.TimeStatistics) *utils.Table
• type E2EPerfCaseConfig
• type E2EPerfScenario
  • func (ts *E2EPerfScenario) GetName() string
  • func (ts *E2EPerfScenario) Init(kubeClient *utils.KubeClient, conf *framework.Config) error
  • func (eps *E2EPerfScenario) Run(results *utils.Results)
• type E2EPerfScenarioConfig
• type NodeFairnessCaseConfig
• type NodeFairnessScenario
  • func (nfs *NodeFairnessScenario) GetName() string
  • func (nfs *NodeFairnessScenario) Init(kubeClient *utils.KubeClient, conf *framework.Config) error
  • func (nfs *NodeFairnessScenario) Run(results *utils.Results)
• type NodeFairnessScenarioConfig
• type RequestConfig
• type ThroughputCaseConfig
• type ThroughputScenario
  • func (ts *ThroughputScenario) GetName() string
  • func (ts *ThroughputScenario) Init(kubeClient *utils.KubeClient, conf *framework.Config) error
  • func (ts *ThroughputScenario) Run(results *utils.Results)
• type ThroughputScenarioConfig

Constants

const E2EPerfScenarioName = "e2e_perf"

const NodeFairnessScenarioName = "node_fairness"

const ThroughputScenarioName = "throughput"

Functions

func CleanupApp

func CleanupApp(appManager framework.AppManager, appInfo *framework.AppInfo, maxWaitTime time.Duration)

func ConvertToRequestInfos

func ConvertToRequestInfos(requestConfigs []*RequestConfig) []*framework.RequestInfo

func LoadScenarioConf

func LoadScenarioConf(conf *framework.Config, scenarioName string, scenarioConf interface{}) error

func ParseTableFromQPSStatistics

func ParseTableFromQPSStatistics(statistics *profiling.QPSStatistics, orderedKeys []framework.TaskConditionType) *utils.Table

func ParseTableFromStatistic

func ParseTableFromStatistic(statistics *profiling.TimeStatistics) *utils.Table

Types

type E2EPerfCaseConfig

type E2EPerfCaseConfig struct {
	Description    string
	SchedulerName  string
	RequestConfigs []*RequestConfig
}

type E2EPerfScenario

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

func (*E2EPerfScenario) GetName

func (ts *E2EPerfScenario) GetName() string

func (*E2EPerfScenario) Init

func (ts *E2EPerfScenario) Init(kubeClient *utils.KubeClient, conf *framework.Config) error

func (*E2EPerfScenario) Run

func (eps *E2EPerfScenario) Run(results *utils.Results)

type E2EPerfScenarioConfig

type E2EPerfScenarioConfig struct {
	CleanUpDelayMs     int
	ShowNumOfLastTasks int
	Cases              []*E2EPerfCaseConfig
}

type NodeFairnessCaseConfig

type NodeFairnessCaseConfig struct {
	NumPodsPerNode     int
	AllocatePercentage int
	ResourceName       string
}

type NodeFairnessScenario

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

func (*NodeFairnessScenario) GetName

func (nfs *NodeFairnessScenario) GetName() string

func (*NodeFairnessScenario) Init

func (nfs *NodeFairnessScenario) Init(kubeClient *utils.KubeClient, conf *framework.Config) error

func (*NodeFairnessScenario) Run

func (nfs *NodeFairnessScenario) Run(results *utils.Results)

type NodeFairnessScenarioConfig

type NodeFairnessScenarioConfig struct {
	SchedulerNames []string
	Cases          []NodeFairnessCaseConfig
}

type RequestConfig

type RequestConfig struct {
	NumPods          int32
	Repeat           int
	PriorityClass    string
	RequestResources map[string]string
	LimitResources   map[string]string
}

type ThroughputCaseConfig

type ThroughputCaseConfig struct {
	Description    string
	RequestConfigs []*RequestConfig
}

type ThroughputScenario

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

func (*ThroughputScenario) GetName

func (ts *ThroughputScenario) GetName() string

func (*ThroughputScenario) Init

func (ts *ThroughputScenario) Init(kubeClient *utils.KubeClient, conf *framework.Config) error

func (*ThroughputScenario) Run

func (ts *ThroughputScenario) Run(results *utils.Results)

type ThroughputScenarioConfig

type ThroughputScenarioConfig struct {
	CleanUpDelayMs int
	SchedulerNames []string
	Cases          []*ThroughputCaseConfig
}