stress

type Alert struct {
	Type      string
	Metric    string
	Value     float64
	Threshold float64
	Timestamp time.Time
	Severity  string
}

type Config struct {
	Duration         time.Duration
	WarmupDuration   time.Duration
	RampUpDuration   time.Duration
	CooldownDuration time.Duration
	TargetRPS        int
	MaxConcurrency   int
	Timeout          time.Duration
}

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

type CostConfig struct {
	CostPerRequest float64
	CostPerMinute  float64
	Currency       string
}

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

type DistributedConfig struct {
	CoordinatorAddress string
	NodeID             string
	IsCoordinator      bool
	HeartbeatInterval  time.Duration
	SyncTimeout        time.Duration
}

type DistributedResult struct {
	NodeResults   []Result
	TotalRequests int64
	SuccessCount  int64
	ErrorCount    int64
	TimeoutCount  int64
	SuccessRate   float64
	ThroughputRPS float64
	AvgLatency    time.Duration
	StartTime     time.Time
	EndTime       time.Time
	Duration      time.Duration
}

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

type DistributedScenario struct {
	*Scenario
	NodeAssignments map[string][]string // scenario -> nodes
	TotalRPS        int
	GeographicDist  map[string]float64 // region -> percentage
}

type DistributedTestConfig struct {
	Name            string
	Scenario        *Scenario
	Duration        time.Duration
	TotalRPS        int
	GeographicDist  map[string]float64
	NodeSelection   LoadBalanceStrategy
	FailOnNodeError bool
}

type GeographicDistribution struct {
	Regions map[string]RegionConfig
}

type GeographicLoad struct {
	Regions map[string]*RegionLoad
}

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

type JobStatus string

type LoadBalanceStrategy string

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

type MetricChange struct {
	Name      string
	Baseline  float64
	Current   float64
	Change    float64
	ChangePct float64
}

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

type MetricDataPoint struct {
	Timestamp  time.Time
	Latency    time.Duration
	Throughput float64
	Errors     int
	CPU        float64
	Memory     float64
}

type Node struct {
	ID       string
	Address  string
	Status   NodeStatus
	Capacity int
	Load     float64
	LastPing time.Time
	// contains filtered or unexported fields
}

type NodeClient interface {
	Connect(address string) error
	Execute(scenario *Scenario) (*Result, error)
	HealthCheck() error
	Close() error
}

type NodeStatus string

type RegionConfig struct {
	Name       string
	Percentage float64
	Nodes      []string
}

type RegionLoad struct {
	Name       string
	Percentage float64
	RPS        int
	Latency    time.Duration
}

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

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

type ResourceMetrics struct {
	CPUPercent  float64
	MemoryMB    float64
	Goroutines  int
	GCRuns      uint32
	HeapAllocMB float64
}

type Result struct {
	Scenario         string
	Type             TestType
	StartTime        time.Time
	EndTime          time.Time
	Duration         time.Duration
	TotalRequests    int64
	SuccessCount     int64
	ErrorCount       int64
	TimeoutCount     int64
	LatencyHistogram map[string]time.Duration
	LatencyP50       time.Duration
	LatencyP95       time.Duration
	LatencyP99       time.Duration
	MinLatency       time.Duration
	MaxLatency       time.Duration
	AvgLatency       time.Duration
	ThroughputRPS    float64
	SuccessRate      float64
	ErrorRate        float64
	Errors           map[string]int
	ResourceUsage    ResourceMetrics
}

type ResultComparison struct {
	Baseline *Result
	Current  *Result
	Changes  map[string]MetricChange
}

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

type Scenario struct {
	Name        string
	Type        TestType
	Description string
	Fn          func(ctx context.Context) error
	Weight      int
}

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

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

type ScenarioTemplate struct {
	Name        string
	Description string
	Type        TestType
	BaseFn      func(ctx context.Context, params map[string]interface{}) error
	Defaults    map[string]interface{}
}

type Schedule struct {
	Type     ScheduleType
	Interval time.Duration
	Cron     string
	At       time.Time
}

type ScheduleType string

type ScheduledJob struct {
	ID       string
	Name     string
	Scenario *Scenario
	Schedule Schedule
	LastRun  time.Time
	NextRun  time.Time
	RunCount int
	MaxRuns  int
	Status   JobStatus
	Results  []Result
}

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

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

type TestType string

type ThresholdConfig struct {
	MaxErrorRate  float64
	MaxLatencyP95 time.Duration
	MinThroughput float64
}

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