telemetry

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

type DashboardEntry struct {
	ID        int64     `json:"id"`
	Timestamp time.Time `json:"timestamp"`
	Type      string    `json:"type"`     // "event", "log", "http", "query", "job", "mail", "redis"
	Category  string    `json:"category"` // more specific e.g. "auth", "db", "cache"
	Level     string    `json:"level,omitempty"`
	Message   string    `json:"message"`
	Data      any       `json:"data,omitempty"`
	Duration  int64     `json:"duration_ms,omitempty"`
}

type LogHandler struct {
	slog.Handler
	// contains filtered or unexported fields
}

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

type QueueStat struct {
	Name       string `json:"name"`
	Pending    int64  `json:"pending"`    // jobs waiting to be processed
	Processing int64  `json:"processing"` // jobs currently in-flight (reserved)
	Failed     int64  `json:"failed"`     // jobs in the dead-letter list
	Scheduled  int64  `json:"scheduled"`  // jobs in the delayed sorted-set
	LastPolled string `json:"last_polled"`
}

type ScheduledJob struct {
	Payload   string    `json:"payload"`
	RunAt     time.Time `json:"run_at"`
	RunAtUnix string    `json:"run_at_unix"`
}