Commit 92bf5baf authored by ztelur's avatar ztelur

fix linter problem

parent c73593d6
......@@ -127,6 +127,8 @@ type Client struct {
// NewClient create a client instance with name, endpoints etc.
func NewClient(name string, endpoints []string, timeout time.Duration, heartbeat int) (*Client, error) {
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
rawClient, err := clientv3.New(clientv3.Config{
Context: ctx,
Endpoints: endpoints,
......
......@@ -18,6 +18,7 @@
package etcdv3
import (
"log"
"net/url"
"os"
"path"
......@@ -97,7 +98,7 @@ func (suite *ClientTestSuite) SetupSuite() {
cfg.Dir = defaultEtcdV3WorkDir
e, err := embed.StartEtcd(cfg)
if err != nil {
t.Fatal(err)
log.Fatal(err)
}
select {
case <-e.Server.ReadyNotify():
......@@ -145,7 +146,7 @@ func (suite *ClientTestSuite) TestClientClose() {
defer c.Close()
if c.rawClient.ActiveConnection().GetState() != connectivity.Ready {
t.Fatal(suite.client.rawClient.ActiveConnection().GetState())
log.Fatal(suite.client.rawClient.ActiveConnection().GetState())
}
}
......@@ -298,7 +299,7 @@ func (suite *ClientTestSuite) TestClientWatch() {
wc, err := c.watch(prefix)
if err != nil {
t.Fatal(err)
log.Fatal(err)
}
events := make([]mvccpb.Event, 0)
......@@ -358,7 +359,7 @@ func (suite *ClientTestSuite) TestClientRegisterTemp() {
completePath := path.Join("scott", "wang")
wc, err := observeC.watch(completePath)
if err != nil {
t.Fatal(err)
log.Fatal(err)
}
events := make([]mvccpb.Event, 0)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment