Merge pull request polarismesh#130 from andrewshan/main

fix: default config not valid

common/utils/funcs.go

@@ -118,3 +118,9 @@ func IsWildName(name string) bool {
 	length := len(name)
 	return length >= 1 && name[length-1:length] == "*"
 }
+
+// NewUUID 返回一个随机的UUID
+func NewUUID() string {
+	uuidBytes := uuid.New()
+	return hex.EncodeToString(uuidBytes[:])
+}

healthcheck/check.go

@@ -26,7 +26,6 @@ import (
 	"github.com/polarismesh/polaris-server/common/srand"
 	"github.com/polarismesh/polaris-server/common/timewheel"
 	"github.com/polarismesh/polaris-server/common/utils"
-	"github.com/polarismesh/polaris-server/naming"
 	"github.com/polarismesh/polaris-server/plugin"
 	"sync"
 	"sync/atomic"
@@ -276,7 +275,7 @@ func setInsDbStatus(instance *api.Instance, status int) error {
 	host := instance.GetHost().GetValue()
 	port := instance.GetPort().GetValue()
 	log.Infof("[Health Check][Check]addr:%s:%d id:%s set db status %d", host, port, id, status)
-	err := server.storage.SetInstanceHealthStatus(id, status, naming.NewUUID())
+	err := server.storage.SetInstanceHealthStatus(id, status, utils.NewUUID())
 	if err != nil {
 		log.Errorf("[Health Check][Check]id: %s set db status err:%s", id, err)
 		return err

polaris-server.yaml

@@ -14,21 +14,12 @@ bootstrap:
   # 注册为北极星服务
   polaris_service:
 #    probe_address: ##DB_ADDR##
-    enable_register: false
+    enable_register: true
     isolated: false
     services:
-      - name: polaris.discover
-        namespace: Polaris
+      - name: polaris.checker
         protocols:
           - grpcserver
-          - httpserver
-          - xdsserverv3
-#          - l5pbserver
-      - name: polaris.healthcheck
-        namespace: Polaris
-        protocols:
-          - grpcserver
-          - httpserver
 # apiserver配置
 apiservers:
   - name: httpserver # 协议名，全局唯一

store/boltdb/default.go

@@ -19,7 +19,10 @@ package boltdb
 
 import (
 	"errors"
+	"github.com/polarismesh/polaris-server/common/model"
+	"github.com/polarismesh/polaris-server/common/utils"
 	"github.com/polarismesh/polaris-server/store"
+	"time"
 )
 
 const (
@@ -63,10 +66,59 @@ func (m *boltStore) Initialize(c *store.Config) error {
 		_ = handler.Close()
 		return err
 	}
+	if err = m.initStoreData(); nil != err {
+		_ = handler.Close()
+		return err
+	}
 	m.start = true
 	return nil
 }
 
+const (
+	namespacePolaris = "Polaris"
+	ownerToInit      = "polaris"
+)
+
+var (
+	namespacesToInit = []string{"default", namespacePolaris}
+	servicesToInit   = []string{"polaris.checker", "polaris.monitor"}
+)
+
+func (m *boltStore) initStoreData() error {
+	for _, namespace := range namespacesToInit {
+		curTime := time.Now()
+		err := m.AddNamespace(&model.Namespace{
+			Name:       namespace,
+			Token:      utils.NewUUID(),
+			Owner:      ownerToInit,
+			Valid:      true,
+			CreateTime: curTime,
+			ModifyTime: curTime,
+		})
+		if nil != err {
+			return err
+		}
+	}
+	for _, svc := range servicesToInit {
+		curTime := time.Now()
+		err := m.AddService(&model.Service{
+			ID:         utils.NewUUID(),
+			Name:       svc,
+			Namespace:  namespacePolaris,
+			Token:      utils.NewUUID(),
+			Owner:      ownerToInit,
+			Revision:   utils.NewUUID(),
+			Valid:      true,
+			CreateTime: curTime,
+			ModifyTime: curTime,
+		})
+		if nil != err {
+			return err
+		}
+	}
+	return nil
+}
+
 func (m *boltStore) newStore() error {
 	m.l5Store = &l5Store{handler: m.handler}
 	if err := m.l5Store.InitL5Data(); nil != err {

store/sqldb/service.go

@@ -20,7 +20,7 @@ package sqldb
 import (
 	"database/sql"
 	"errors"
-	"github.com/polarismesh/polaris-server/naming"
+	"github.com/polarismesh/polaris-server/common/utils"
 	"github.com/polarismesh/polaris-server/store"
 	"strings"
 	"time"
@@ -1244,7 +1244,7 @@ func addOwnerServiceMap(tx *BaseTx, service, namespace, owner string) error {
 	if len(owners) >= 1 {
 		for i := 0; i < len(owners); i++ {
 			addSql += "(?,?,?,?),"
-			args = append(args, naming.NewUUID(), owners[i], service, namespace)
+			args = append(args, utils.NewUUID(), owners[i], service, namespace)
 		}
 		if len(args) != 0 {
 			addSql = strings.TrimSuffix(addSql, ",")

version

@@ -1 +1 @@
-v1.3.0
+v1.3.1