monitoring

type AppStats struct {
	Name        string  `json:"name"`
	Version     string  `json:"version"`
	Environment string  `json:"environment"`
	Uptime      int64   `json:"uptime"`       // in seconds
	MemoryUsage int64   `json:"memory_usage"` // in bytes
	CPUUsage    float64 `json:"cpu_usage"`    // percentage
	Requests    int64   `json:"requests"`
	Errors      int64   `json:"errors"`
}

type CacheStats struct {
	Driver      string  `json:"driver"`
	Connected   bool    `json:"connected"`
	HitCount    int64   `json:"hit_count"`
	MissCount   int64   `json:"miss_count"`
	HitRate     float64 `json:"hit_rate"`     // percentage
	MemoryUsage int64   `json:"memory_usage"` // in bytes
}

type CronCollector interface {
	GetTasks() ([]TaskInfo, error)
	GetExecutions(limit int) ([]ExecutionInfo, error)
	GetTaskExecutions(taskName string, limit int) ([]ExecutionInfo, error)
}

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

type CronStats struct {
	Driver      string          `json:"driver"`
	Tasks       []TaskInfo      `json:"tasks"`
	Executions  []ExecutionInfo `json:"executions"`
	LastUpdated time.Time       `json:"last_updated"`
}

type DatabaseStats struct {
	Driver       string `json:"driver"`
	Connected    bool   `json:"connected"`
	ActiveConns  int    `json:"active_connections"`
	IdleConns    int    `json:"idle_connections"`
	MaxConns     int    `json:"max_connections"`
	QueryCount   int64  `json:"query_count"`
	SlowQueries  int64  `json:"slow_queries"`
	AvgQueryTime int    `json:"avg_query_time"` // in milliseconds
}

type ExecutionInfo struct {
	TaskName   string    `json:"task_name"`
	StartedAt  time.Time `json:"started_at"`
	FinishedAt time.Time `json:"finished_at,omitempty"`
	Duration   int       `json:"duration"` // in milliseconds
	Status     string    `json:"status"`   // running, completed, failed
	Error      string    `json:"error,omitempty"`
	Output     string    `json:"output,omitempty"`
}

type FailedJobInfo struct {
	ID         string    `json:"id"`
	Job        string    `json:"job"`
	Queue      string    `json:"queue"`
	Error      string    `json:"error"`
	FailedAt   time.Time `json:"failed_at"`
	Retries    int       `json:"retries"`
	MaxRetries int       `json:"max_retries"`
}

type QueueCollector interface {
	GetQueueStats() (map[string]QueueInfo, error)
	GetWorkers() ([]WorkerInfo, error)
	GetFailedJobs() ([]FailedJobInfo, error)
}

type QueueInfo struct {
	Name        string `json:"name"`
	Size        int    `json:"size"`
	Processing  int    `json:"processing"`
	Completed   int    `json:"completed"`
	Failed      int    `json:"failed"`
	Throughput  int    `json:"throughput"`    // jobs per minute
	AvgWaitTime int    `json:"avg_wait_time"` // in seconds
}

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

type QueueStats struct {
	Driver      string               `json:"driver"`
	Queues      map[string]QueueInfo `json:"queues"`
	Workers     []WorkerInfo         `json:"workers"`
	FailedJobs  []FailedJobInfo      `json:"failed_jobs"`
	LastUpdated time.Time            `json:"last_updated"`
}

type StorageStats struct {
	Driver     string `json:"driver"`
	Connected  bool   `json:"connected"`
	TotalFiles int64  `json:"total_files"`
	TotalSize  int64  `json:"total_size"` // in bytes
	FreeSpace  int64  `json:"free_space"` // in bytes
}

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

type SystemStats struct {
	App         AppStats      `json:"app"`
	Database    DatabaseStats `json:"database"`
	Queue       *QueueStats   `json:"queue,omitempty"`
	Cron        *CronStats    `json:"cron,omitempty"`
	Cache       CacheStats    `json:"cache"`
	Storage     StorageStats  `json:"storage"`
	LastUpdated time.Time     `json:"last_updated"`
}

type TaskInfo struct {
	Name         string    `json:"name"`
	Schedule     string    `json:"schedule"`
	Description  string    `json:"description"`
	Enabled      bool      `json:"enabled"`
	LastRun      time.Time `json:"last_run,omitempty"`
	NextRun      time.Time `json:"next_run,omitempty"`
	RunCount     int       `json:"run_count"`
	SuccessCount int       `json:"success_count"`
	FailureCount int       `json:"failure_count"`
	AvgDuration  int       `json:"avg_duration"` // in milliseconds
}

type WorkerInfo struct {
	ID         string    `json:"id"`
	Status     string    `json:"status"` // idle, working, stopped
	CurrentJob string    `json:"current_job,omitempty"`
	Processed  int       `json:"processed"`
	Failed     int       `json:"failed"`
	StartedAt  time.Time `json:"started_at"`
	LastJobAt  time.Time `json:"last_job_at,omitempty"`
}