etcd 3.7.0-beta.0：RangeStream 流式读取与 v2store 彻底告别

# 启动一个测试 etcd 集群（单节点，仅用于本地验证）
etcd --data-dir=/tmp/etcd-test-data --listen-client-urls=http://127.0.0.1:2379 \
     --advertise-client-urls=http://127.0.0.1:2379 &

# 写入一批测试数据
for i in $(seq 1 5000); do
  etcdctl put "/apps/config/key$i" "value$i"
done

# 传统 Range：一次性返回所有 key，观察延迟和内存峰值
etcdctl get /apps/config/ --prefix --limit-key-number=5000

# RangeStream：流式分块返回，延迟更均匀
etcdctl get /apps/config/ --prefix --stream

package main

import (
    "context"
    "fmt"
    "log"
    "time"

    "go.etcd.io/etcd/client/v3"
)

func main() {
    cli, err := clientv3.New(clientv3.Config{
        Endpoints:   []string{"http://127.0.0.1:2379"},
        DialTimeout: 5 * time.Second,
    })
    if err != nil {
        log.Fatal(err)
    }
    defer cli.Close()

    ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    defer cancel()

    // 使用 RangeStream 获取 /apps/config/ 下所有 key
    // client/v3 的 Get 在 v3.7 客户端中已支持流式模式
    // 以下为基于 v3.7 客户端 SDK 的预期用法（beta 阶段 API 可能微调）
    stream, err := cli.RangeStream(ctx, &clientv3.RangeStreamRequest{
        Key:      []byte("/apps/config/"),
        RangeEnd: []byte("/apps/config0"), // prefix range: key ≥ prefix 且 < prefix+1
    })
    if err != nil {
        log.Fatal(err)
    }

    count := 0
    for resp := range stream.Recv() {
        for _, kv := range resp.Kvs {
            count++
            if count <= 10 {
                fmt.Printf("key: %s  value: %s\n", string(kv.Key), string(kv.Value))
            }
        }
    }
    fmt.Printf("总共收到 %d 条记录（流式分块返回）\n", count)
}

# 检查集群当前存储版本（v3.6+ 应已完全使用 v3store）
etcdctl endpoint status --write-out=table

# 检查是否还有 v2 key（在 v3.6 及更早版本中可能残留）
ETCDCTL_API=3 etcdctl get "" --prefix --keys-only | grep -c "^"

# 检查 etcd 版本
etcdctl version

# 如果你的集群还在 v3.5 或更早，先升级到 v3.6.11
# v3.6.11 是官方建议的跳板版本，移除 v2 的过渡工作在其中已基本完成

# 推荐的升级路径：3.4 → 3.5 → 3.6.11 → 3.7（正式版发布后）
# 每一步都应按官方滚动升级文档操作，逐个节点替换

# 单节点测试环境快速验证升级流程
etcdctl member list
# 记录 member ID 后，逐个节点：
# 1. 停止旧版本 etcd
# 2. 用新版本二进制启动，指向同一 data-dir
# 3. 等待集群健康后继续下一个节点
etcdctl endpoint health

# 下载二进制
# https://github.com/etcd-io/etcd/releases/tag/v3.7.0-beta.0

# 或直接拉取官方容器镜像
docker pull quay.io/coreos/etcd:v3.7.0-beta.0
docker run --rm quay.io/coreos/etcd:v3.7.0-beta.0 etcd --version