1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

service KV {
  rpc Range(RangeRequest) returns (RangeResponse) {
      option (google.api.http) = {
        post: "/v3beta/kv/range"
        body: "*"
    };
  }

  rpc Put(PutRequest) returns (PutResponse) {
      option (google.api.http) = {
        post: "/v3beta/kv/put"
        body: "*"
    };
  }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19

cli, err := clientv3.New(clientv3.Config{
    Endpoints:   []string{"127.0.0.1:2379"},
    Context:     ctx,
    DialTimeout: 3 * time.Second,
    DialOptions: []grpc.DialOption{},
})

// handle error
ch := cli.Watch(ctx, "/some/keyspace", clientv3.WithPrefix())
for resp := range ch {
    for _, event = range resp.Events {
        switch event.Type {
        case mvccpb.PUT:
            // process with put event
        case mvccpb.DELETE:
            // process with delete event
        }
    }
}