Current state: Under Discussion
...
Code Block |
---|
// milvus.proto message CreateAliasRequest { common.MsgBase base = 1; string collection_name = 2; string alias = 3; } message DropAliasRequest { common.MsgBase base = 1; string collection_namealias = 2; string alias = 3; } message AlterAliasRequest{ common.MsgBase base = 1; string collection_name = 2; string alias = 3; } service MilvusService { // NEW rpc CreateAlias(SetAliasRequest) returns (common.Status) {} // NEW rpc DropAlias(DropAliasRequest) returns (common.Status) {} // NEW rpc AlterAlias(AlterAliasRequest) returns (common.Status) {} } |
...
The recovery process will handle CreateAliasDDType , DropAliasDDType, AlterAliasDDType types.
Code Block |
---|
func (c *Core) reSendDdMsg(ctx context.Context) error { flag, err := c.MetaTable.client.Load(DDMsgSendPrefix, 0) if err != nil || flag == "true" { log.Debug("No un-successful DdMsg") return nil } ddOpStr, err := c.MetaTable.client.Load(DDOperationPrefix, 0) if err != nil { log.Debug("DdOperation key does not exist") return nil } var ddOp DdOperation if err = json.Unmarshal([]byte(ddOpStr), &ddOp); err != nil { return err } switch ddOp.Type { case CreateCollectionDDType: var ddReq = internalpb.CreateCollectionRequest{} if err = proto.UnmarshalText(ddOp.Body, &ddReq); err != nil { return err } collInfo, err := c.MetaTable.GetCollectionByName(ddReq.CollectionName, 0) if err != nil { return err } if err = c.SendDdCreateCollectionReq(ctx, &ddReq, collInfo.PhysicalChannelNames); err != nil { return err } // NEW case CreateAliasDDType: ... case DropAliasDDType: ... case AlterAliasDDType: ... ... } |
...