Closed veloting closed 1 year ago
`package main
import ( "fmt" "time"
"github.com/rpcxio/libkv/store" "github.com/rpcxio/rpcx-etcd/store/etcdv3"
)
func main() { etcdv3.Register() kv, err := etcdv3.New( []string{"127.0.0.1:2379"}, &store.Config{ ConnectionTimeout: 3 * time.Second, Username: "user", Password: "pwd", }, ) if err != nil { fmt.Println(err) return } kv.Put("test", []byte("test"), nil) select {} } `
希望能设计成 keeplive失效的时候重新grant之后在put和keepalive(需要保存keepalive的key,val)
try v0.3.1 please
`package main
import ( "fmt" "time"
)
func main() { etcdv3.Register() kv, err := etcdv3.New( []string{"127.0.0.1:2379"}, &store.Config{ ConnectionTimeout: 3 * time.Second, Username: "user", Password: "pwd", },
)
if err != nil { fmt.Println(err) return }
kv.Put("test", []byte("test"), nil) select {} } `
希望能设计成 keeplive失效的时候重新grant之后在put和keepalive(需要保存keepalive的key,val)