metrics

type CacheBatchLoadMetrics struct {
	TargetsTotal     int64     `json:"targets_total"`
	TargetsScheduled int64     `json:"targets_scheduled"`
	TargetsCompleted int64     `json:"targets_completed"`
	TargetsFailed    int64     `json:"targets_failed"`
	TargetsSkipped   int64     `json:"targets_skipped"`
	InFlight         int64     `json:"in_flight"`
	IsRunning        bool      `json:"is_running"`
	LastStartedAt    time.Time `json:"last_started_at"`
	LastFinishedAt   time.Time `json:"last_finished_at"`
}

type CacheBatchLoadSource interface {
	GetMetrics() CacheBatchLoadMetrics
}

type CachePreloadMetrics struct {
	TasksScheduled int64         `json:"tasks_scheduled"`
	TasksCompleted int64         `json:"tasks_completed"`
	TasksFailed    int64         `json:"tasks_failed"`
	TasksCancelled int64         `json:"tasks_cancelled"`
	TasksSkipped   int64         `json:"tasks_skipped"`
	TotalDuration  time.Duration `json:"total_duration"`
	IsEnabled      bool          `json:"is_enabled"`
}

type CachePreloadSnapshot struct {
	TasksScheduled int64
	TasksCompleted int64
	TasksFailed    int64
	TasksCancelled int64
	TasksSkipped   int64
	TotalDuration  time.Duration
}

type CachePreloadSource interface {
	GetMetrics() CachePreloadSnapshot
	IsEnabled() bool
}

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

type FileProcessingMetrics struct {
	TotalFound      uint64 `json:"total_found"`
	AlreadyExisting uint64 `json:"already_existing"`
	NewlyInserted   uint64 `json:"newly_inserted"`
	SkippedInvalid  uint64 `json:"skipped_invalid"`
	InFlight        int64  `json:"in_flight"`
}

type FileProcessorSource interface {
	GetStats() FileProcessingMetrics
}

type HTTPCacheConfig struct {
	MaxEntrySize int64
	MaxTotalSize int64
}

type HTTPCacheMetrics struct {
	Enabled      bool  `json:"enabled"`
	SizeBytes    int64 `json:"size_bytes"`
	MaxEntrySize int64 `json:"max_entry_size"`
	MaxTotalSize int64 `json:"max_total_size"`
	EntryCount   int64 `json:"entry_count"`
}

type HTTPCacheSource interface {
	IsEnabled() bool
	GetSizeBytes() int64
	GetEntryCount() int64
	GetConfig() HTTPCacheConfig
}

type ModuleStatus struct {
	Name          string    `json:"name"`
	Status        string    `json:"status"` // "active", "idle", "recent"
	LastActiveAt  time.Time `json:"last_active_at"`
	ActivityCount int64     `json:"activity_count"`
}

type RuntimeMetrics struct {
	NumGoroutine    int           `json:"num_goroutine"`
	NumCPU          int           `json:"num_cpu"`
	NumCgoCall      int64         `json:"num_cgo_call"`
	MemAlloc        uint64        `json:"mem_alloc"`
	MemTotalAlloc   uint64        `json:"mem_total_alloc"`
	MemSys          uint64        `json:"mem_sys"`
	MemHeapAlloc    uint64        `json:"mem_heap_alloc"`
	MemHeapSys      uint64        `json:"mem_heap_sys"`
	MemHeapInuse    uint64        `json:"mem_heap_inuse"`
	MemHeapReleased uint64        `json:"mem_heap_released"`
	MemHeapObjects  uint64        `json:"mem_heap_objects"`
	GCSys           uint64        `json:"gc_sys"`
	LastGC          time.Time     `json:"last_gc"`
	NextGC          uint64        `json:"next_gc"`
	GCCPUFraction   float64       `json:"gc_cpu_fraction"`
	Uptime          time.Duration `json:"uptime"`
}

type Snapshot struct {
	Timestamp      time.Time             `json:"timestamp"`
	Runtime        RuntimeMetrics        `json:"runtime"`
	WriteBatcher   WriteBatcherMetrics   `json:"writebatcher"`
	WorkerPool     WorkerPoolMetrics     `json:"worker_pool"`
	CachePreload   CachePreloadMetrics   `json:"cache_preload"`
	CacheBatchLoad CacheBatchLoadMetrics `json:"cache_batch_load"`
	FileProcessing FileProcessingMetrics `json:"file_processing"`
	HTTPCache      HTTPCacheMetrics      `json:"http_cache"`
	Modules        []ModuleStatus        `json:"modules"`
	QueueLength    int                   `json:"queue_length"`
	QueueCapacity  int                   `json:"queue_capacity"`
}

type WorkerPoolMetrics struct {
	RunningWorkers  int64  `json:"running_workers"`
	SubmittedTasks  uint64 `json:"submitted_tasks"`
	WaitingTasks    uint64 `json:"waiting_tasks"`
	SuccessfulTasks uint64 `json:"successful_tasks"`
	FailedTasks     uint64 `json:"failed_tasks"`
	CompletedTasks  uint64 `json:"completed_tasks"`
	DroppedTasks    uint64 `json:"dropped_tasks"`
	MaxWorkers      int    `json:"max_workers"`
	MinWorkers      int    `json:"min_workers"`
}

type WorkerPoolSource interface {
	GetStats() WorkerPoolStats
}

type WorkerPoolStats struct {
	RunningWorkers  int64
	SubmittedTasks  uint64
	WaitingTasks    uint64
	SuccessfulTasks uint64
	FailedTasks     uint64
	CompletedTasks  uint64
	DroppedTasks    uint64
	MaxWorkers      int
	MinWorkers      int
}

type WriteBatcherMetrics struct {
	PendingCount  int64     `json:"pending_count"`
	ChannelSize   int       `json:"channel_size"`
	MaxBatchSize  int       `json:"max_batch_size"`
	FlushInterval string    `json:"flush_interval"`
	IsClosed      bool      `json:"is_closed"`
	LastFlushTime time.Time `json:"last_flush_time"`
	TotalFlushed  int64     `json:"total_flushed"`
	TotalErrors   int64     `json:"total_errors"`
	DQueEnabled   bool      `json:"dque_enabled"`
	DQueSize      int       `json:"dque_size"`
	OverflowCount int64     `json:"overflow_count"`
}

type WriteBatcherSource interface {
	PendingCount() int64
	GetStats() WriteBatcherStats
}

type WriteBatcherStats struct {
	ChannelSize   int
	MaxBatchSize  int
	FlushInterval time.Duration
	IsClosed      bool
	TotalFlushed  int64
	TotalErrors   int64
	OverflowCount int64
	DQueEnabled   bool
	DQueSize      int
}