Utilizing Redis Streams for Event Logging in Go

package main

import (
    "fmt"
    "log"
    "github.com/redis/go-redis/v9"
    "context"
)

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

    // Example usage
    streamName := "user_activity_stream"
    _, err := client.XAdd(ctx, &redis.XAddArgs{
        Stream: streamName,
        Values: map[string]interface{}{"event": "login", "username": "alice"},
    }).Result()
    if err != nil {
        log.Fatalf("could not add entry: %v", err)
    }

    _, err = client.XAdd(ctx, &redis.XAddArgs{
        Stream: streamName,
        Values: map[string]interface{}{"event": "login", "username": "bob"},
    }).Result()
    if err != nil {
        log.Fatalf("could not add entry: %v", err)
    }

    entries, err := client.XRead(ctx, &redis.XReadArgs{
        Streams: []string{streamName, "0"},
        Count:   2,
        Block:   0,
    }).Result()
    if err != nil {
        log.Fatalf("could not read entries: %v", err)
    }

    for _, entry := range entries[0].Messages {
        fmt.Printf("Stream entry: %v\n", entry)
    }
}