load

type LoadTest struct {
	Name        string
	Description string
	App         *lift.App
	Scenarios   []Scenario
	Config      LoadTestConfig
	// contains filtered or unexported fields
}

type LoadTestConfig struct {
	Duration     time.Duration // How long to run the test
	Concurrent   int           // Number of concurrent workers
	RampUpTime   time.Duration // Time to ramp up to full concurrency
	RampDownTime time.Duration // Time to ramp down
	MaxRequests  int64         // Maximum number of requests (0 = unlimited)
	ThinkTime    time.Duration // Delay between requests per worker
	Timeout      time.Duration // Request timeout

	// Rate limiting
	RequestsPerSecond float64 // Target RPS (0 = unlimited)

	// Reporting
	ReportInterval time.Duration // How often to report progress
	Percentiles    []float64     // Percentiles to calculate (default: 50, 95, 99)
}

type Results struct {
	// Test metadata
	TestName  string        `json:"test_name"`
	StartTime time.Time     `json:"start_time"`
	EndTime   time.Time     `json:"end_time"`
	Duration  time.Duration `json:"duration"`

	// Request statistics
	TotalRequests  int64   `json:"total_requests"`
	SuccessCount   int64   `json:"success_count"`
	ErrorCount     int64   `json:"error_count"`
	RequestsPerSec float64 `json:"requests_per_sec"`

	// Response time statistics
	MinLatency    time.Duration `json:"min_latency"`
	MaxLatency    time.Duration `json:"max_latency"`
	MeanLatency   time.Duration `json:"mean_latency"`
	MedianLatency time.Duration `json:"median_latency"`

	// Percentiles
	Percentiles map[string]time.Duration `json:"percentiles"`

	// Error breakdown
	ErrorsByType   map[string]int64 `json:"errors_by_type"`
	ErrorsByStatus map[int]int64    `json:"errors_by_status"`

	// Scenario breakdown
	ScenarioStats map[string]*ScenarioStats `json:"scenario_stats"`

	// Throughput
	BytesRead    int64   `json:"bytes_read"`
	BytesWritten int64   `json:"bytes_written"`
	Throughput   float64 `json:"throughput_mbps"`

	// Raw data for analysis
	Latencies []time.Duration `json:"-"` // Not serialized due to size
}

type Scenario struct {
	Name        string
	Description string
	Weight      int // Relative frequency (higher = more frequent)
	Setup       func() (any, error)
	Execute     func(context.Context, *lift.App, any) (*ScenarioResult, error)
	Validate    func(*ScenarioResult) error
	Cleanup     func(any) error
}

type ScenarioResult struct {
	StatusCode   int
	ResponseTime time.Duration
	BytesRead    int64
	BytesWritten int64
	Error        error
	Headers      map[string]string
	Body         []byte
	Metadata     map[string]any
}

type ScenarioStats struct {
	Name           string           `json:"name"`
	Count          int64            `json:"count"`
	SuccessCount   int64            `json:"success_count"`
	ErrorCount     int64            `json:"error_count"`
	MeanLatency    time.Duration    `json:"mean_latency"`
	MinLatency     time.Duration    `json:"min_latency"`
	MaxLatency     time.Duration    `json:"max_latency"`
	ErrorsByType   map[string]int64 `json:"errors_by_type"`
	ErrorsByStatus map[int]int64    `json:"errors_by_status"`
}