package main

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

func main() {
	client := red.NewClient(&red.Options{
		Addr:     "127.0.0.1:6379", // Redis地址
		Password: "",               // 密码（如果有的话）
		DB:       0,                // 使用默认DB
	})
	defer client.Close()

	ctx := context.Background()
	for i := 0; i < 100; i++ {
		val, err := client.XAdd(ctx, &red.XAddArgs{
			Stream: "test_stream",
			Values: map[string]interface{}{
				"key1": "value1",
				"key2": i + 1,
			},
		}).Result()
		fmt.Printf("val: %v, err: %v\n", val, err)
	}
}