每日一库：ETCD in go

package main

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

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

func main() {
    // 创建 ETCD 客户端连接
    cfg := client.Config{
        Endpoints:   []string{"http://localhost:2379"}, // ETCD 地址
        DialTimeout: 5 * time.Second,
    }
    client, err := client.New(cfg)
    if err != nil {
        log.Fatal(err)
    }
    defer client.Close()

    // 创建 KV 客户端
    kv := clientv3.NewKV(client)

    // 设置键值对
    key := "example_key"
    value := "example_value"
    _, err = kv.Put(context.Background(), key, value)
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("Key '%s' set to '%s'\n", key, value)

    // 获取键值对
    getResp, err := kv.Get(context.Background(), key)
    if err != nil {
        log.Fatal(err)
    }
    if len(getResp.Kvs) > 0 {
        fmt.Printf("Value for key '%s': %s\n", key, getResp.Kvs[0].Value)
    } else {
        fmt.Printf("Key '%s' not found\n", key)
    }

    // 使用 Watch 机制实时监测数据变化
    watcher := clientv3.NewWatcher(client)
    watchChan := watcher.Watch(context.Background(), key)
    fmt.Println("Waiting for changes...")
    for resp := range watchChan {
        for _, event := range resp.Events {
            fmt.Printf("Event type: %s, Key: %s, Value: %s\n", event.Type, event.Kv.Key, event.Kv.Value)
        }
    }
}