Documentation
¶
Index ¶
- type Orchestrator
- type Progress
- func (p *Progress) AddError(err string)
- func (p *Progress) GetPercentComplete() float64
- func (p *Progress) GetPhasePercent() float64
- func (p *Progress) GetSummary() string
- func (p *Progress) IncrementCollected(count int)
- func (p *Progress) IncrementCompleted(count int)
- func (p *Progress) IncrementConnected(count int)
- func (p *Progress) IncrementFailed(count int)
- func (p *Progress) IncrementPrepared(count int)
- func (p *Progress) IncrementStartedClients(count int)
- func (p *Progress) IncrementStartedServers(count int)
- func (p *Progress) Print()
- func (p *Progress) SetPhase(phase string)
- func (p *Progress) SetTotals(nodes, tests, servers, clients int)
- type TestState
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Orchestrator ¶
type Orchestrator struct {
// contains filtered or unexported fields
}
Orchestrator manages the execution of distributed tests
func NewOrchestrator ¶
func NewOrchestrator(clientPool *client.Pool, saveDaemonResults bool, saveRawResults bool, rawResultsDir string) *Orchestrator
NewOrchestrator creates a new test orchestrator
func (*Orchestrator) ExecuteTest ¶
ExecuteTest executes a complete test workflow
func (*Orchestrator) GetErrors ¶
func (o *Orchestrator) GetErrors() []error
GetErrors returns any errors encountered during execution
func (*Orchestrator) GetState ¶
func (o *Orchestrator) GetState() TestState
GetState returns the current orchestrator state
type Progress ¶
type Progress struct {
// Total counts
TotalNodes int
TotalTests int
TotalServers int
TotalClients int
// Progress counts
ConnectedNodes int
PreparedNodes int
StartedServers int
StartedClients int
CompletedTests int
FailedTests int
CollectedResults int
// Timing
StartTime time.Time
CurrentPhase string
PhaseStart time.Time
// Errors
Errors []string
// contains filtered or unexported fields
}
Progress tracks test execution progress
func (*Progress) GetPercentComplete ¶
GetPercentComplete returns the overall completion percentage
func (*Progress) GetPhasePercent ¶
GetPhasePercent returns the current phase completion percentage
func (*Progress) GetSummary ¶
GetSummary returns a summary string
func (*Progress) IncrementCollected ¶
IncrementCollected increments collected results count
func (*Progress) IncrementCompleted ¶
IncrementCompleted increments completed tests count
func (*Progress) IncrementConnected ¶
IncrementConnected increments connected nodes count
func (*Progress) IncrementFailed ¶
IncrementFailed increments failed tests count
func (*Progress) IncrementPrepared ¶
IncrementPrepared increments prepared nodes count
func (*Progress) IncrementStartedClients ¶
IncrementStartedClients increments started clients count
func (*Progress) IncrementStartedServers ¶
IncrementStartedServers increments started servers count
type TestState ¶
type TestState string
TestState represents the current state of test execution
const ( StateInit TestState = "init" StateConnecting TestState = "connecting" StatePreparing TestState = "preparing" StateStartingServers TestState = "starting_servers" StateStartingClients TestState = "starting_clients" StateRunning TestState = "running" StateCollecting TestState = "collecting" StateComplete TestState = "complete" StateFailed TestState = "failed" )
Source Files