Versions in this module Expand all Collapse all v1 v1.0.0 Apr 5, 2022 Changes in this version + const ParallelResultCalculation + const PerformanceDataVersion + const TestResultVersion + type PortIncrement int + const PortIncrementClientPort + const PortIncrementDefaultPort + const PortIncrementRaftPort + type TestManagerConfig struct + MaxAgents int + type TestRunManager struct + func NewTestRunManager(c *coordinator.Coordinator, am *agents.AgentsManager, ...) (*TestRunManager, error) + func (t *TestRunManager) BreakAndTerminateAllCmds(tr *common.TestRun, cmds []runningCommand) error + func (t *TestRunManager) CalculateFlameGraph(tr *common.TestRun, commandID string) error + func (t *TestRunManager) CalculatePerformancePlot(tr *common.TestRun, commandID, plotType string) error + func (t *TestRunManager) CalculateResults(tr *common.TestRun, recalc bool) (*common.TestResult, error) + func (t *TestRunManager) CheckPreseed(tr *common.TestRun) error + func (t *TestRunManager) CompileBinaries(tr *common.TestRun, seeder bool) error + func (t *TestRunManager) Config() TestManagerConfig + func (t *TestRunManager) ContinueSweep(tr *common.TestRun, sweepID string) + func (t *TestRunManager) CopyOutputs(tr *common.TestRun, envs map[int32][]byte, ignoreErrors bool) error + func (t *TestRunManager) CreateStartSequenceAtomizer(tr *common.TestRun, archiverDone chan []runningCommand, errChan chan error) []startSequenceEntry + func (t *TestRunManager) CreateStartSequenceTwoPhase(tr *common.TestRun) []startSequenceEntry + func (t *TestRunManager) DeployBinaries(tr *common.TestRun, binariesInS3Path string) (map[int32][]byte, error) + func (t *TestRunManager) DeployConfig(tr *common.TestRun, envs map[int32][]byte, cfg []byte) error + func (t *TestRunManager) ExecuteTestRun(tr *common.TestRun) + func (t *TestRunManager) FailRoles(tr *common.TestRun, cancel chan bool) + func (t *TestRunManager) FailTestRun(tr *common.TestRun, err error) + func (t *TestRunManager) GenerateConfig(tr *common.TestRun) ([]byte, error) + func (t *TestRunManager) GenerateConfigAtomizer(tr *common.TestRun) ([]byte, error) + func (t *TestRunManager) GenerateConfigTwoPhase(tr *common.TestRun) ([]byte, error) + func (t *TestRunManager) GenerateMatrix() ([]*common.MatrixResult, time.Time, time.Time) + func (t *TestRunManager) GenerateMatrixForRuns(trs []*common.TestRun) ([]*common.MatrixResult, time.Time, time.Time) + func (t *TestRunManager) GenerateSweepMatrix(sweepIDs []string) ([]*common.MatrixResult, time.Time, time.Time) + func (t *TestRunManager) GetAllRolesSorted(tr *common.TestRun, role common.SystemRole) []*common.TestRunRole + func (t *TestRunManager) GetLogFiles(tr *common.TestRun, cmds []runningCommand, envs map[int32][]byte) error + func (t *TestRunManager) GetPerformanceProfiles(tr *common.TestRun, cmds []runningCommand, envs map[int32][]byte) error + func (t *TestRunManager) GetRequiredVCPUs(tr *common.TestRun) map[string]int32 + func (t *TestRunManager) GetRoleEndpoint(tr *common.TestRun, role *common.TestRunRole, portIncrement PortIncrement) (string, error) + func (t *TestRunManager) GetTestRun(runID string) (*common.TestRun, bool) + func (t *TestRunManager) GetTestRuns() []*common.TestRun + func (t *TestRunManager) HandleCommandFailure(tr *common.TestRun, allCmds []runningCommand, envs map[int32][]byte, ...) error + func (t *TestRunManager) HasAWSRoles(tr *common.TestRun) bool + func (t *TestRunManager) Is2PC(architectureID string) bool + func (t *TestRunManager) IsAtomizer(architectureID string) bool + func (t *TestRunManager) KillAwsAgents(tr *common.TestRun) error + func (t *TestRunManager) LoadAllTestRuns() + func (t *TestRunManager) LoadConfig() error + func (t *TestRunManager) LoadTestResult(tr *common.TestRun) + func (t *TestRunManager) LoadTestRun(id string) (*common.TestRun, error) + func (t *TestRunManager) NormalizeRole(role common.SystemRole) common.SystemRole + func (t *TestRunManager) PersistConfig() error + func (t *TestRunManager) PersistTestRun(tr *common.TestRun) + func (t *TestRunManager) PreseedShards(tr *common.TestRun, envs map[int32][]byte) error + func (t *TestRunManager) RedownloadTestOutputsFromS3(tr *common.TestRun) error + func (t *TestRunManager) Reschedule(tr *common.TestRun) + func (t *TestRunManager) ResultCalculator() + func (t *TestRunManager) RetrySpawn(id string) + func (t *TestRunManager) RunBinaries(tr *common.TestRun, envs map[int32][]byte, cmd chan *common.ExecutedCommand, ...) error + func (t *TestRunManager) RunBinariesAtomizer(tr *common.TestRun, envs map[int32][]byte, cmd chan *common.ExecutedCommand, ...) error + func (t *TestRunManager) RunBinariesTwoPhase(tr *common.TestRun, envs map[int32][]byte, cmd chan *common.ExecutedCommand, ...) error + func (t *TestRunManager) RunForAllAgents(f func(role *common.TestRunRole) error, tr *common.TestRun, description string, ...) error + func (t *TestRunManager) ScheduleTestRun(tr *common.TestRun) + func (t *TestRunManager) Scheduler() + func (t *TestRunManager) SetMaxAgents(max int) error + func (t *TestRunManager) ShouldCalculateResults(tr *common.TestRun) bool + func (t *TestRunManager) ShouldTerminate(tr *common.TestRun) bool + func (t *TestRunManager) SnapshotAgents(tr *common.TestRun) + func (t *TestRunManager) SpawnAWSInstances(tr *common.TestRun) bool + func (t *TestRunManager) StartRoleBinaries(cmds []runningCommand, roles []*common.TestRunRole, tr *common.TestRun, ...) ([]runningCommand, error) + func (t *TestRunManager) SubstituteParameters(params []string, r *common.TestRunRole, tr *common.TestRun) []string + func (t *TestRunManager) Terminate(id string) + func (t *TestRunManager) TerminateIfNeeded(tr *common.TestRun, allCmds []runningCommand, envs map[int32][]byte, ...) bool + func (t *TestRunManager) TestRunsLoaded() bool + func (t *TestRunManager) UpdateStatus(tr *common.TestRun, newStatus common.TestRunStatus, details string) + func (t *TestRunManager) UploadBinaries(tr *common.TestRun, seeder bool) (string, error) + func (t *TestRunManager) UploadConfig(cfg []byte, tr *common.TestRun) error + func (t *TestRunManager) ValidateTestRun(tr *common.TestRun) []error + func (t *TestRunManager) ValidateTestRunAtomizer(tr *common.TestRun) []error + func (t *TestRunManager) ValidateTestRunTwoPhase(tr *common.TestRun) []error + func (t *TestRunManager) WaitForAWSInstances(tr *common.TestRun) (bool, bool, bool) + func (t *TestRunManager) WaitForRoleOnline(tr *common.TestRun, role *common.TestRunRole, portIncrement PortIncrement, ...) error + func (t *TestRunManager) WaitForRolesOnline(tr *common.TestRun, roles []*common.TestRunRole, portIncrement PortIncrement, ...) error + func (t *TestRunManager) WriteLog(tr *common.TestRun, format string, a ...interface{})