You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicecomb.apache.org by li...@apache.org on 2022/03/07 01:17:24 UTC

[servicecomb-service-center] branch master updated: [bug] move the time setting of the service to the disco layer (#1285)

This is an automated email from the ASF dual-hosted git repository.

littlecui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/servicecomb-service-center.git


The following commit(s) were added to refs/heads/master by this push:
     new 51a3c23  [bug] move the time setting of the service to the disco layer (#1285)
51a3c23 is described below

commit 51a3c23b1e34268022f78333d589f4ea73a883e1
Author: robotljw <79...@qq.com>
AuthorDate: Mon Mar 7 09:17:17 2022 +0800

    [bug] move the time setting of the service to the disco layer (#1285)
---
 datasource/etcd/ms.go            |  2 --
 datasource/mongo/ms.go           |  2 --
 server/service/disco/metadata.go | 10 ++++++++++
 3 files changed, 10 insertions(+), 4 deletions(-)

diff --git a/datasource/etcd/ms.go b/datasource/etcd/ms.go
index 73da1d3..ab3e723 100644
--- a/datasource/etcd/ms.go
+++ b/datasource/etcd/ms.go
@@ -82,8 +82,6 @@ func (ds *MetadataManager) RegisterService(ctx context.Context, request *pb.Crea
 		ctx = util.SetContext(ctx, uuid.ContextKey, index)
 		service.ServiceId = uuid.Generator().GetServiceID(ctx)
 	}
-	service.Timestamp = strconv.FormatInt(time.Now().Unix(), 10)
-	service.ModTimestamp = service.Timestamp
 
 	data, err := json.Marshal(service)
 	if err != nil {
diff --git a/datasource/mongo/ms.go b/datasource/mongo/ms.go
index 8999c71..58f0cd3 100644
--- a/datasource/mongo/ms.go
+++ b/datasource/mongo/ms.go
@@ -74,8 +74,6 @@ func (ds *MetadataManager) RegisterService(ctx context.Context, request *discove
 		ctx = util.SetContext(ctx, uuid.ContextKey, util.StringJoin([]string{domain, project, service.Environment, service.AppId, service.ServiceName, service.Alias, service.Version}, "/"))
 		service.ServiceId = uuid.Generator().GetServiceID(ctx)
 	}
-	service.Timestamp = strconv.FormatInt(time.Now().Unix(), 10)
-	service.ModTimestamp = service.Timestamp
 	// the service unique index in table is (serviceId/serviceEnv,serviceAppid,servicename,serviceVersion)
 	if len(service.Alias) != 0 {
 		serviceID, err := GetServiceID(ctx, &discovery.MicroServiceKey{
diff --git a/server/service/disco/metadata.go b/server/service/disco/metadata.go
index 8c1f430..fc2478b 100644
--- a/server/service/disco/metadata.go
+++ b/server/service/disco/metadata.go
@@ -20,6 +20,8 @@ package disco
 import (
 	"context"
 	"fmt"
+	"strconv"
+	"time"
 
 	"github.com/apache/servicecomb-service-center/datasource"
 	"github.com/apache/servicecomb-service-center/pkg/log"
@@ -69,9 +71,17 @@ func registerService(ctx context.Context, request *pb.CreateServiceRequest) (*pb
 		return nil, quotaErr
 	}
 
+	assignDefaultValue(service)
+
 	return datasource.GetMetadataManager().RegisterService(ctx, request)
 }
 
+func assignDefaultValue(service *pb.MicroService) {
+	formatTenBase := 10
+	service.Timestamp = strconv.FormatInt(time.Now().Unix(), formatTenBase)
+	service.ModTimestamp = service.Timestamp
+}
+
 func registerServiceDetails(ctx context.Context, in *pb.CreateServiceRequest, serviceID string) (*pb.CreateServiceResponse, error) {
 	var chanLen = 0
 	errorsCh := make(chan error, 10)