Commit bc1e1e28 authored by wangwx's avatar wangwx

fix comments

parent 22d0b82a
...@@ -33,12 +33,12 @@ import ( ...@@ -33,12 +33,12 @@ import (
var ( var (
// ErrNilETCDV3Client raw client nil // ErrNilETCDV3Client raw client nil
ErrNilETCDV3Client = perrors.New("etcd raw Client is nil") // full describe the ERR ErrNilETCDV3Client = perrors.New("etcd raw client is nil") // full describe the ERR
// ErrKVPairNotFound not found key // ErrKVPairNotFound not found key
ErrKVPairNotFound = perrors.New("k/v pair not found") ErrKVPairNotFound = perrors.New("k/v pair not found")
) )
// NewConfigClient create new client // NewConfigClient create new Client
func NewConfigClient(opts ...Option) *Client { func NewConfigClient(opts ...Option) *Client {
options := &Options{ options := &Options{
Heartbeat: 1, // default Heartbeat Heartbeat: 1, // default Heartbeat
...@@ -184,7 +184,7 @@ func (c *Client) keepSessionLoop(s *concurrency.Session) { ...@@ -184,7 +184,7 @@ func (c *Client) keepSessionLoop(s *concurrency.Session) {
for { for {
select { select {
case <-c.Done(): case <-c.Done():
// client be stopped, will clean the client hold resources // Client be stopped, will clean the client hold resources
return return
case <-s.Done(): case <-s.Done():
log.Print("etcd server stopped") log.Print("etcd server stopped")
......
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