monitoring

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

type Stats struct {
	JobsEnqueued   int64                   `json:"jobs_enqueued"`
	JobsScheduled  int64                   `json:"jobs_scheduled"`
	JobsStarted    int64                   `json:"jobs_started"`
	JobsCompleted  int64                   `json:"jobs_completed"`
	JobsFailed     int64                   `json:"jobs_failed"`
	JobsCancelled  int64                   `json:"jobs_cancelled"`
	JobsRetrying   int64                   `json:"jobs_retrying"`
	TotalProcessed int64                   `json:"total_processed"`
	SuccessRate    float64                 `json:"success_rate"`
	AvgDuration    time.Duration           `json:"avg_duration"`
	Uptime         time.Duration           `json:"uptime"`
	TaskTypeStats  map[string]TaskTypeStat `json:"task_type_stats"`
}

type TaskTypeMetrics struct {
	Enqueued      int64
	Completed     int64
	Failed        int64
	TotalDuration int64 // in nanoseconds
	Count         int64
}

type TaskTypeStat struct {
	Enqueued    int64         `json:"enqueued"`
	Completed   int64         `json:"completed"`
	Failed      int64         `json:"failed"`
	SuccessRate float64       `json:"success_rate"`
	AvgDuration time.Duration `json:"avg_duration"`
}