etcd_test.go
1.36 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
package etcd
import (
"context"
"fmt"
"go.etcd.io/etcd/api/v3/mvccpb"
clientv3 "go.etcd.io/etcd/client/v3"
"pro2d/common"
"pro2d/common/logger"
"testing"
)
func TestEtcdClient_GetByPrefix(t *testing.T) {
err := NewEtcdClient(common.GlobalConf.Etcd)
if err != nil {
logger.Error(err)
return
}
gameInfo := GEtcdClient().GetByPrefix(common.GlobalConf.AccountConf.Name)
for k, v := range gameInfo {
logger.Debug("game info key: %v val: %v", k, v)
}
rch := GEtcdClient().etcd.Watch(context.Background(), fmt.Sprintf("/%s/", common.GlobalConf.AccountConf.Name), clientv3.WithPrefix())
go func() {
for wresp := range rch {
for _, ev := range wresp.Events {
switch ev.Type {
case mvccpb.PUT: //修改或者新增
logger.Debug("account put key: %s val: %s", ev.Kv.Key, ev.Kv.Value)
case mvccpb.DELETE: //删除
logger.Debug("account delete key: %s val: %s", ev.Kv.Key, ev.Kv.Value)
}
}
}
}()
game := GEtcdClient().etcd.Watch(context.Background(), fmt.Sprintf("/%s/", common.GlobalConf.GameConf.Name), clientv3.WithPrefix())
for wresp := range game {
for _, ev := range wresp.Events {
switch ev.Type {
case mvccpb.PUT: //修改或者新增
logger.Debug("game put key: %s val: %s", ev.Kv.Key, ev.Kv.Value)
case mvccpb.DELETE: //删除
logger.Debug("game delete key: %s val: %s", ev.Kv.Key, ev.Kv.Value)
}
}
}
}