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:
...
...
} |
...