fix(zookeeper-registry): Support the options of WithoutKeepAlive for zookeeper(#86)

registries/zookeeper/registry/options.go

@@ -26,11 +26,12 @@ import (
 )
 
 type Options struct {
-	Servers        []string
-	RegistryGroup  string
-	Username       string
-	Password       string
-	SessionTimeout time.Duration
+	Servers         []string
+	RegistryGroup   string
+	Username        string
+	Password        string
+	CloseRenewLease bool //
+	SessionTimeout  time.Duration
 }
 
 func (o *Options) Apply(opts []Option) {
@@ -105,3 +106,14 @@ func WithPassword(password string) Option {
 		o.Password = password
 	}}
 }
+
+// WithHasRenewLease configures the RenewLease so that .You can control whether to enable
+// the renewal of the Ephemeral node, which is very helpful for debugging the
+// development environment.
+// Default keep here is ,for details please refer to
+// https://github.com/kitex-contrib/codec-dubbo/issues/86
+func WithHasRenewLease(isRenew bool) Option {
+	return Option{F: func(o *Options) {
+		o.CloseRenewLease = isRenew
+	}}
+}

registries/zookeeper/registry/registry.go

@@ -89,7 +89,11 @@ func (z *zookeeperRegistry) Register(info *registry.Info) error {
 	}
 	ctx, cancel := context.WithCancel(context.Background())
 	z.canceler.add(finalPath, cancel)
-	go z.keepalive(ctx, finalPath, nil)
+
+	if !z.opt.CloseRenewLease {
+		go z.keepalive(ctx, finalPath, nil)
+	}
+
 	return nil
 }
 

registries/zookeeper/resolver/options.go

@@ -26,11 +26,12 @@ import (
 )
 
 type Options struct {
-	Servers        []string
-	RegistryGroup  string
-	SessionTimeout time.Duration
-	Username       string
-	Password       string
+	Servers         []string
+	RegistryGroup   string
+	SessionTimeout  time.Duration
+	Username        string
+	Password        string
+	CloseRenewLease bool
 }
 
 func (o *Options) Apply(opts []Option) {
@@ -105,3 +106,12 @@ func WithPassword(password string) Option {
 		o.Password = password
 	}}
 }
+
+// WithHasRenewLease configures the RenewLease so that .You can control whether to enable
+// the renewal of the Ephemeral node, which is very helpful for debugging the
+// development environment.
+func WithHasRenewLease(isRenew bool) Option {
+	return Option{F: func(o *Options) {
+		o.CloseRenewLease = isRenew
+	}}
+}