Add dbID to data service proto

Signed-off-by: Nsunby <bingyi.sun@zilliz.com>

internal/dataservice/param.go

@@ -182,7 +182,7 @@ func (p *ParamTable) initSegmentInfoChannelName() {
 
 func (p *ParamTable) initDataServiceSubscriptionName() {
 	var err error
-	p.DataServiceSubscriptionName, err = p.Load("msgChannel.subNamePrefix.dataServiceSubNamePrefix")
+	p.DataServiceSubscriptionName, err = p.Load("msgChannel.chanNamePrefix.dataServiceSubNamePrefix")
 	if err != nil {
 		panic(err)
 	}

internal/dataservice/server.go

@@ -122,14 +122,14 @@ func (s *Server) Start() error {
 	}
 	s.ddHandler = newDDHandler(s.meta, s.segAllocator)
 	s.initSegmentInfoChannel()
+	if err = s.initMsgProducer(); err != nil {
+		return err
+	}
 	if err = s.loadMetaFromMaster(); err != nil {
 		return err
 	}
 	s.startServerLoop()
 	s.waitDataNodeRegister()
-	if err = s.initMsgProducer(); err != nil {
-		return err
-	}
 	s.state.Store(internalpb2.StateCode_HEALTHY)
 	log.Println("start success")
 	return nil

internal/proto/data_service.proto

@@ -63,6 +63,7 @@ message ShowSegmentRequest {
   common.MsgBase base = 1;
   int64  collectionID = 2;
   int64  partitionID = 3;
+  int64  dbID = 4;
 }
 
 message ShowSegmentResponse {
@@ -148,8 +149,8 @@ message SegmentMsg{
 
 message CollectionStatsRequest{
   common.MsgBase base = 1;
-  string db_name = 2;
-  string collection_name = 3;
+  string dbID = 2;
+  string collectionID = 3;
 }
 
 message CollectionStatsResponse {
@@ -159,9 +160,9 @@ message CollectionStatsResponse {
 
 message PartitionStatsRequest{
   common.MsgBase base = 1;
-  string db_name = 2;
-  string collection_name = 3;
-  string partition_name = 4;
+  string dbID = 2;
+  string collectionID = 3;
+  string partitionID = 4;
 }
 
 message PartitionStatsResponse {