Feature/polaris feat: Add Polaris support

.github/workflows/gf.yml

@@ -8,6 +8,7 @@ on:
     - develop
     - feature/**
     - fix/**
+
   pull_request:
     branches:
     - master
@@ -89,7 +90,11 @@ jobs:
           - 9000:9000
           - 8123:8123
           - 9001:9001
-
+      polaris:
+        image: huyuanxin/polaris-server-with-config:latest
+        ports:
+          - 8090:8090
+          - 8091:8091
 
     strategy:
       matrix:

contrib/registry/etcd/etcd.go

@@ -10,19 +10,21 @@ package etcd
 import (
 	"time"
 
+	etcd3 "go.etcd.io/etcd/client/v3"
+
 	"github.com/gogf/gf/v2/errors/gcode"
 	"github.com/gogf/gf/v2/errors/gerror"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/net/gsvc"
 	"github.com/gogf/gf/v2/os/glog"
 	"github.com/gogf/gf/v2/text/gstr"
-	etcd3 "go.etcd.io/etcd/client/v3"
 )
 
 var (
 	_ gsvc.Registry = &Registry{}
 )
 
+// Registry implements gsvc.Registry interface.
 type Registry struct {
 	client       *etcd3.Client
 	kv           etcd3.KV
@@ -31,15 +33,19 @@ type Registry struct {
 	logger       *glog.Logger
 }
 
+// Option is the option for the etcd registry.
 type Option struct {
 	Logger       *glog.Logger
 	KeepaliveTTL time.Duration
 }
 
 const (
+	// DefaultKeepAliveTTL is the default keepalive TTL.
 	DefaultKeepAliveTTL = 10 * time.Second
+	separator           = "/"
 )
 
+// New creates and returns a new etcd registry.
 func New(address string, option ...Option) *Registry {
 	endpoints := gstr.SplitAndTrim(address, ",")
 	if len(endpoints) == 0 {
@@ -54,6 +60,7 @@ func New(address string, option ...Option) *Registry {
 	return NewWithClient(client, option...)
 }
 
+// NewWithClient creates and returns a new etcd registry with the given client.
 func NewWithClient(client *etcd3.Client, option ...Option) *Registry {
 	r := &Registry{
 		client: client,

contrib/registry/etcd/etcd_registry.go

@@ -9,9 +9,10 @@ package etcd
 import (
 	"context"
 
+	etcd3 "go.etcd.io/etcd/client/v3"
+
 	"github.com/gogf/gf/v2/errors/gerror"
 	"github.com/gogf/gf/v2/net/gsvc"
-	etcd3 "go.etcd.io/etcd/client/v3"
 )
 
 func (r *Registry) Register(ctx context.Context, service *gsvc.Service) error {
@@ -42,6 +43,7 @@ func (r *Registry) Register(ctx context.Context, service *gsvc.Service) error {
 		return err
 	}
 	go r.doKeepAlive(grant.ID, keepAliceCh)
+	service.Separator = separator
 	return nil
 }
 
@@ -64,7 +66,7 @@ func (r *Registry) doKeepAlive(leaseID etcd3.LeaseID, keepAliceCh <-chan *etcd3.
 
 		case res, ok := <-keepAliceCh:
 			if res != nil {
-				//r.logger.Debugf(ctx, `keepalive loop: %v, %s`, ok, res.String())
+				// r.logger.Debugf(ctx, `keepalive loop: %v, %s`, ok, res.String())
 			}
 			if !ok {
 				r.logger.Noticef(ctx, `keepalive exit, lease id: %d`, leaseID)

contrib/registry/polaris/.gitignore

@@ -0,0 +1,11 @@
+### Example user template template
+### Example user template
+
+# IntelliJ project files
+.idea
+*.iml
+out
+gen
+
+*.log
+*.json

contrib/registry/polaris/doc.go

@@ -0,0 +1,8 @@
+// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
+//
+// This Source Code Form is subject to the terms of the MIT License.
+// If a copy of the MIT was not distributed with this file,
+// You can obtain one at https://github.com/gogf/gf.
+
+// Package polaris implements service Registry and Discovery using polaris.
+package polaris

contrib/registry/polaris/go.mod

@@ -0,0 +1,10 @@
+module github.com/gogf/gf/contrib/registry/polaris/v2
+
+go 1.15
+
+require (
+	github.com/gogf/gf/v2 v2.0.0
+	github.com/polarismesh/polaris-go v1.1.0
+)
+
+replace github.com/gogf/gf/v2 => ../../../