|
@@ -41,15 +41,15 @@ func (n *Node) RegisterWithContext(ctx context.Context, serverCode string, serve
|
|
}
|
|
}
|
|
log.Printf("service registed gateway for %s success!\n", key)
|
|
log.Printf("service registed gateway for %s success!\n", key)
|
|
//续租约
|
|
//续租约
|
|
- keepAlive, err := n.Client.KeepAlive(ctx, lease.ID)
|
|
|
|
|
|
+ _, err = n.Client.KeepAlive(ctx, lease.ID)
|
|
if err != nil {
|
|
if err != nil {
|
|
return nil, err
|
|
return nil, err
|
|
}
|
|
}
|
|
- go func() {
|
|
|
|
- for {
|
|
|
|
- <-keepAlive
|
|
|
|
- }
|
|
|
|
- }()
|
|
|
|
|
|
+ //go func() {
|
|
|
|
+ // for {
|
|
|
|
+ // <-keepAlive
|
|
|
|
+ // }
|
|
|
|
+ //}()
|
|
return func() {
|
|
return func() {
|
|
_, _ = n.Client.Revoke(ctx, lease.ID)
|
|
_, _ = n.Client.Revoke(ctx, lease.ID)
|
|
}, nil
|
|
}, nil
|