Added --redis command line option to choose which Redis to use

Author: kpumuk

README.md

@@ -29,6 +29,14 @@ go install github.com/kpumuk/lazykiq@latest
 - `/` - filter job list (case-sensitive)
 - `q` - quit
 
+### Redis
+
+Connect to a specific Redis instance with:
+
+```bash
+lazykiq --redis redis://localhost:6379/0
+```
+
 ## Development
 
 We use [`mise`](https://mise.jdx.dev/) for development. Install tooling with:
@@ -74,4 +82,4 @@ I’d love to hear your thoughts on this project. Feel free to drop a note!
 
 ## License
 
-[MIT](https://github.com/kpumuk/lazykiq/raw/main/LICENSE).
+[MIT](https://github.com/kpumuk/lazykiq/raw/main/LICENSE).

cmd/lazykiq/root.go

@@ -12,6 +12,7 @@ import (
 	"github.com/charmbracelet/fang"
 	"github.com/spf13/cobra"
 
+	"github.com/kpumuk/lazykiq/internal/sidekiq"
 	"github.com/kpumuk/lazykiq/internal/ui"
 )
 
@@ -75,12 +76,31 @@ func init() {
 		"help for lazykiq",
 	)
 
+	rootCmd.Flags().String(
+		"redis",
+		"redis://localhost:6379/0",
+		"redis URL",
+	)
+
 	rootCmd.RunE = func(cmd *cobra.Command, _ []string) error {
 		cpuprofile, err := cmd.Flags().GetString("cpuprofile")
 		if err != nil {
 			return fmt.Errorf("parse cpuprofile flag: %w", err)
 		}
 
+		redisURL, err := cmd.Flags().GetString("redis")
+		if err != nil {
+			return fmt.Errorf("parse redis flag: %w", err)
+		}
+
+		client, err := sidekiq.NewClient(redisURL)
+		if err != nil {
+			return fmt.Errorf("create redis client: %w", err)
+		}
+		defer func() {
+			_ = client.Close()
+		}()
+
 		var profileFile *os.File
 		if cpuprofile != "" {
 			file, err := os.Create(cpuprofile)
@@ -98,7 +118,7 @@ func init() {
 			}()
 		}
 
-		app := ui.New()
+		app := ui.New(client)
 		p := tea.NewProgram(app, tea.WithAltScreen())
 		if _, err := p.Run(); err != nil {
 			return fmt.Errorf("run lazykiq: %w", err)

internal/sidekiq/client.go

@@ -3,6 +3,7 @@ package sidekiq
 import (
 	"context"
 	"encoding/json"
+	"fmt"
 	"strconv"
 	"strings"
 	"time"
@@ -59,24 +60,27 @@ type Client struct {
 	redis *redis.Client
 }
 
-// NewClient creates a new Sidekiq client with hardcoded Redis connection
-func NewClient() *Client {
-	// Disable connection pool logging by setting MaxRetries to 0
-	// This prevents the pool from retrying and logging errors
-	rdb := redis.NewClient(&redis.Options{
-		Addr:         "localhost:6379",
-		Password:     "",
-		DB:           0,
-		MaxRetries:   -1,              // Disable retries completely
-		DialTimeout:  2 * time.Second, // Short timeout to fail fast
-		ReadTimeout:  2 * time.Second,
-		WriteTimeout: 2 * time.Second,
-		PoolSize:     1, // Minimal pool size
-	})
-
-	return &Client{
-		redis: rdb,
+// NewClient creates a new Sidekiq client configured from a Redis URL.
+func NewClient(redisURL string) (*Client, error) {
+	if redisURL == "" {
+		redisURL = "redis://localhost:6379/0"
 	}
+
+	opts, err := redis.ParseURL(redisURL)
+	if err != nil {
+		return nil, fmt.Errorf("parse redis url: %w", err)
+	}
+
+	// Disable connection pool logging by disabling retries entirely.
+	opts.MaxRetries = -1               // Disable retries completely
+	opts.DialTimeout = 2 * time.Second // Short timeout to fail fast
+	opts.ReadTimeout = 2 * time.Second
+	opts.WriteTimeout = 2 * time.Second
+	opts.PoolSize = 1 // Minimal pool size
+
+	rdb := redis.NewClient(opts)
+
+	return &Client{redis: rdb}, nil
 }
 
 // Close closes the Redis connection

internal/ui/app.go

@@ -40,11 +40,9 @@ type App struct {
 }
 
 // New creates a new App instance
-func New() App {
+func New(client *sidekiq.Client) App {
 	styles := theme.NewStyles()
 
-	client := sidekiq.NewClient()
-
 	viewList := []views.View{
 		views.NewDashboard(client),
 		views.NewBusy(client),