ycsb

type HistogramBucket struct {
	Min   time.Duration
	Max   time.Duration
	Count int
}

type LatencySnapshot struct {
	P50  float64
	P95  float64
	P99  float64
	P999 float64
}

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

type OpType int

type OperationStats struct {
	Count       int
	ErrorCount  int
	MinLatency  time.Duration
	MaxLatency  time.Duration
	AvgLatency  time.Duration
	P50Latency  time.Duration
	P95Latency  time.Duration
	P99Latency  time.Duration
	P999Latency time.Duration
}

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

type Result struct {
	Ops       int
	Duration  time.Duration
	Errors    int
	Latencies []time.Duration // All operation latencies
}

type ThroughputPoint struct {
	Time      time.Duration // Time since start
	OpsPerSec float64
	OpType    OpType
}

type ThroughputSummary struct {
	MinThroughput    float64
	MaxThroughput    float64
	AvgThroughput    float64
	StdDevThroughput float64
	ThroughputTrend  string // "increasing", "decreasing", "stable"
}

type WorkloadSpec struct {
	Weights [OpNum]float64 // Fraction for each op type
}

type YCSBConfig struct {
	Addr               string        // Address of the cache service (host:port or comma-separated)
	ConnMode           string        // Connection mode: auto, simple, or cluster
	TopologyRefresh    time.Duration // Topology refresh interval (cluster mode only)
	ConnectionPoolSize int           // Number of connections per address (default: 4)
	NumKeys            int           // Number of unique keys to use in the benchmark
	ValueSize          int           // Size of each value in bytes
	NumOps             int           // Total number of operations to perform
	Concurrency        int           // Number of concurrent workers
	Workload           string        // Workload type or custom mix (e.g. "A", "B", "read=70,update=30")
	Seed               int64         // Seed for random number generation (for reproducibility)
	NoProgress         bool          // Disable progress output during benchmark
	ForceStreaming     bool          // Force streaming for all operations regardless of size
}