|
|
@ -109,7 +109,7 @@ func (r *SvcDiscoveryRegistryImpl) keepAliveLease(leaseID clientv3.LeaseID) {
|
|
|
|
|
|
|
|
|
|
|
|
for ka := range ch {
|
|
|
|
for ka := range ch {
|
|
|
|
if ka != nil {
|
|
|
|
if ka != nil {
|
|
|
|
fmt.Printf("Received lease keep-alive response: %v", ka)
|
|
|
|
fmt.Printf("Received lease keep-alive response: %v\n", ka)
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
fmt.Printf("Lease keep-alive response channel closed")
|
|
|
|
fmt.Printf("Lease keep-alive response channel closed")
|
|
|
|
break
|
|
|
|
break
|
|
|
|