Go etcd初探

package main

import (
    "context"
    "flag"
    "log"
    "strings"
    "time"

    "github.com/coreos/etcd/mvcc/mvccpb"

    "github.com/coreos/etcd/clientv3"
)

var (
    addr = flag.String("addr", "127.0.0.1:2380", "etcd addr")
)

func main() {
    flag.Parse()

    addrs := strings.Split(*addr, ",")

    cli, err := clientv3.New(clientv3.Config{
        Endpoints: addrs,
    })

    if nil != err {
        panic(err)
    }

    defer cli.Close()

    if _, err := cli.Put(context.TODO(), "haha", "{1,1,3}"); nil != err {
        log.Fatal(err)
    }

    {
        resp, err := cli.Get(context.TODO(), "haha")
        if nil != err {
            log.Fatal(err)
        }
        log.Println("resp=", resp)
    }

    go func() {

        timer := time.NewTimer(time.Second * 20)
        ticker := time.NewTicker(time.Second * 2)

        for {
            select {
            case <-ticker.C:
                resp, _ := cli.Grant(context.TODO(), 1)
                ctx, _ := context.WithTimeout(context.Background(), 5*time.Second)
                cli.Put(ctx, "node1", `{"addr":"192.168.1.1:9999"}`, clientv3.WithLease(resp.ID))
            case <-timer.C:
                return
            }
        }
    }()

    { //watch
        rch := cli.Watch(context.Background(), "", clientv3.WithPrefix())
        for wresp := range rch {
            for _, ev := range wresp.Events {
                log.Println(ev)
                if ev.IsCreate() {
                    log.Println("IsCreate")
                } else if ev.IsModify() {
                    log.Println("IsModify")
                } else if ev.Type == mvccpb.DELETE {
                    log.Println("DELETE")
                } else if ev.Type == mvccpb.PUT {
                    log.Println("PUT")
                }

            }
        }
    }

}