profiling

type AnalysisResult struct {
	Timestamp       time.Time
	Bottlenecks     []Bottleneck
	Summary         string
	Metrics         *RuntimeMetrics
	Recommendations []string
}

type Bottleneck struct {
	Type        BottleneckType
	Severity    string // "critical", "high", "medium", "low"
	Component   string
	Description string
	Impact      float64 // Percentage impact on performance
	Suggestions []string
	Details     map[string]interface{}
}

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

type BottleneckType string

type ChannelMetrics struct {
	BufferSize     int
	MaxUtilization int
	AvgUtilization float64
	BlockedTime    time.Duration
	// contains filtered or unexported fields
}

type ConnectorMetrics struct {
	Name             string
	Type             string
	RecordsProcessed int64
	BytesProcessed   int64
	Errors           int64
	ConnectionTime   time.Duration
	TotalTime        time.Duration
	BatchCount       int64
	AvgBatchSize     float64
}

type MetricsSample struct {
	Timestamp     time.Time
	AllocBytes    uint64
	NumGoroutines int
	GCPauseNs     uint64
}

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

type ProfileConfig struct {
	// Profile types to collect
	Types []ProfileType

	// Output directory for profile files
	OutputDir string

	// Duration for CPU profiling
	CPUDuration time.Duration

	// Memory profile rate (0 = default rate)
	MemProfileRate int

	// Block profile rate (0-100, 0 = disabled)
	BlockProfileRate int

	// Mutex profile fraction (0-100, 0 = disabled)
	MutexProfileFraction int

	// Whether to collect runtime metrics
	CollectRuntimeMetrics bool

	// Sampling interval for runtime metrics
	MetricsSamplingInterval time.Duration

	// Whether to generate flame graphs
	GenerateFlameGraphs bool
}

type ProfileResult struct {
	// Overall metrics
	Duration       time.Duration
	Throughput     float64 // records/sec
	ByteThroughput float64 // bytes/sec
	ErrorRate      float64 // errors/total

	// Stage breakdown
	StageMetrics map[string]*StageMetrics

	// Connector metrics
	SourceMetrics *ConnectorMetrics
	DestMetrics   *ConnectorMetrics

	// Channel metrics
	ChannelMetrics *ChannelMetrics

	// System metrics
	RuntimeMetrics *RuntimeMetrics

	// Bottleneck analysis
	BottleneckAnalysis *AnalysisResult

	// Recommendations
	Recommendations []string
}

type ProfileType string

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

type RuntimeMetrics struct {
	// Memory metrics
	AllocBytes      uint64
	TotalAllocBytes uint64
	SysBytes        uint64
	NumGC           uint32
	GCPauseTotal    time.Duration
	GCPauseLast     time.Duration

	// Goroutine metrics
	NumGoroutines int

	// CPU metrics
	NumCPU     int
	GOMAXPROCS int

	// Samples over time
	Samples []MetricsSample
}

type StageMetrics struct {
	Name           string
	RecordsIn      int64
	RecordsOut     int64
	ProcessingTime time.Duration
	ErrorCount     int64
	AvgLatency     time.Duration
	MaxLatency     time.Duration
	MinLatency     time.Duration
	// contains filtered or unexported fields
}