http

type Agent struct {
	// config info
	ID            string
	CollectorHost string
	AgentHost     string
	TestURL       string
	TestMethod    string
	// contains filtered or unexported fields
}

type AgentInfo struct {
	ID       string      `json:"id"`
	Callback string      `json:"callback"`
	URL      string      `json:"url"`
	Method   string      `json:"method"`
	Status   AgentStatus `json:"status"`
}

type AgentStatus string

type Builder struct {
	strings.Builder
}

type CollectorServer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type HTTPReqParams struct {
	URL     string
	Method  string
	Headers map[string]string
	Body    []byte
	// contains filtered or unexported fields
}

type PerfTestData struct {
	ID     string `json:"id"`     // test id
	URL    string `json:"url"`    // test url
	Method string `json:"method"` // test method

	TotalDuration float64 `json:"total_duration"` // unit: s
	TotalRequests int64   `json:"total_requests"`
	SuccessCount  int64   `json:"success_count"`
	ErrorCount    int64   `json:"error_count"`
	QPS           float64 `json:"qps"` // unit: req/sec

	AvgLatency float64 `json:"avg_latency"` // unit: ms
	P25Latency float64 `json:"p25_latency"` // unit: ms
	P50Latency float64 `json:"p50_latency"` // unit: ms
	P95Latency float64 `json:"p95_latency"` // unit: ms
	P99Latency float64 `json:"p99_latency"` // unit: ms
	MaxLatency float64 `json:"max_latency"` // unit: ms
	MinLatency float64 `json:"min_latency"` // unit: ms

	TotalSent     int64 `json:"total_sent"`     // unit: bytes
	TotalReceived int64 `json:"total_received"` // unit: bytes

	StatusCodes map[int]int64 `json:"status_codes"`
	CreatedAt   string        `json:"created_at"`
	Status      string        `json:"status"`   // running, finished, stopped
	AgentID     string        `json:"agent_id"` // agent identify

	Errors []string `json:"errors"` // error details
}

type PerfTestHTTP struct {
	ID string // performance test ID

	Client *http.Client
	Params *HTTPReqParams

	Worker        int
	TotalRequests uint64
	Duration      time.Duration

	PushURL           string
	PrometheusJobName string
	// contains filtered or unexported fields
}

type Result struct {
	Duration   time.Duration
	ReqSize    int64
	RespSize   int64
	StatusCode int
	Err        error
}

type Statistics struct {
	ID string `json:"id"` // Performance Test ID

	URL    string `json:"url"`    // performed request URL
	Method string `json:"method"` // request method
	Body   string `json:"body"`   // request body (JSON)

	TotalRequests uint64   `json:"total_requests"` // total requests
	TotalDuration float64  `json:"total_duration"` //  total duration (seconds)
	SuccessCount  uint64   `json:"success_count"`  // successful requests (status code 2xx)
	ErrorCount    uint64   `json:"error_count"`    // failed requests (status code not 2xx)
	Errors        []string `json:"errors"`         // error details

	QPS        float64 `json:"qps"`         // requests per second (Throughput)
	AvgLatency float64 `json:"avg_latency"` // average latency (ms)
	P25Latency float64 `json:"p25_latency"` // 25th percentile latency (ms)
	P50Latency float64 `json:"p50_latency"` // 50th percentile latency (ms)
	P95Latency float64 `json:"p95_latency"` // 95th percentile latency (ms)
	P99Latency float64 `json:"p99_latency"` // 95th percentile latency (ms)
	MinLatency float64 `json:"min_latency"` // minimum latency (ms)
	MaxLatency float64 `json:"max_latency"` // maximum latency (ms)

	TotalSent     int64 `json:"total_sent"`     // total sent (bytes)
	TotalReceived int64 `json:"total_received"` // total received (bytes)

	StatusCodes map[int]int64 `json:"status_codes"` // status code distribution (count)

	CreatedAt time.Time `json:"created_at"` // created time

	Status  string `json:"status"`   // running, finished
	AgentID string `json:"agent_id"` // identify agent
}

type TestSession struct {
	sync.Mutex
	TestID           string
	Status           TestStatus
	ExpectedAgents   int
	Agents           map[string]*AgentInfo
	TestingReports   map[string]PerfTestData // agentID -> PerfTestData
	FinalReports     map[string]PerfTestData // agentID -> PerfTestData
	AggregatedReport *PerfTestData
	CreatedAt        time.Time
}

type TestStatus string