aggregator

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

type Summary struct {
	TotalTests       int     `json:"total_tests"`
	CompletedTests   int     `json:"completed_tests"`
	FailedTests      int     `json:"failed_tests"`
	AvgThroughput    float64 `json:"avg_throughput_bps"`
	MinThroughput    float64 `json:"min_throughput_bps"`
	MaxThroughput    float64 `json:"max_throughput_bps"`
	TotalRetransmits int64   `json:"total_retransmits"`
}

type TestResult struct {
	TestID        string                 `json:"test_id"`
	SourceNode    string                 `json:"source_node"`
	DestNode      string                 `json:"dest_node"`
	Status        string                 `json:"status"`
	StartTime     int64                  `json:"start_time"`
	EndTime       int64                  `json:"end_time"`
	Duration      int64                  `json:"duration"`
	ErrorMessage  string                 `json:"error_message,omitempty"`
	IperfData     map[string]interface{} `json:"iperf_data,omitempty"`
	ThroughputBps float64                `json:"throughput_bps,omitempty"`
	Retransmits   int64                  `json:"retransmits,omitempty"`
}