Handling Commands with Pipelines in Go

package main

import (
    "context"
    "encoding/json"
    "fmt"
    "time"
    "github.com/redis/go-redis/v9"
)

// User represents a user data structure
type User struct {
    Name  string `json:"name"`
    Age   int    `json:"age"`
    Email string `json:"email"`
}

func main() {
    // Connect to Redis
    client := redis.NewClient(&redis.Options{
        Addr: "localhost:6379",
        DB:   0, // use default DB
    })
    ctx := context.Background()

    // User data
    users := []struct {
        Username string
        Data     User
    }{
        {"alice", User{"Alice", 30, "alice@example.com"}},
        {"bob", User{"Bob", 25, "bob@example.com"}},
    }

    // Use a pipeline to set user data with an expiration
    pipeline := client.Pipeline()
    for _, user := range users {
        jsonData, err := json.Marshal(user.Data)
        if err != nil {
            fmt.Println("Error marshaling user data:", err)
            return
        }
        pipeline.Set(ctx, fmt.Sprintf("user:%s", user.Username), jsonData, 24*time.Hour)
    }
    _, err := pipeline.Exec(ctx)
    if err != nil {
        fmt.Println("Error executing pipeline:", err)
        return
    }

    // Retrieve and print user data to verify
    val, err := client.Get(ctx, "user:alice").Result()
    if err != nil {
        fmt.Println("Error retrieving user data:", err)
        return
    }

    var user User
    err = json.Unmarshal([]byte(val), &user)
    if err != nil {
        fmt.Println("Error unmarshaling user data:", err)
        return
    }
    fmt.Printf("Retrieved User: %v\n", user)
}