File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -4852,11 +4852,13 @@ func (c *CreateAliasTask) SetTs(ts Timestamp) {
48524852 c .Base .Timestamp = ts
48534853}
48544854
4855+ // OnEnqueue defines the behavior task enqueued
48554856func (c * CreateAliasTask ) OnEnqueue () error {
48564857 c .Base = & commonpb.MsgBase {}
48574858 return nil
48584859}
48594860
4861+ // PreExecute defines the action before task execution
48604862func (c * CreateAliasTask ) PreExecute (ctx context.Context ) error {
48614863 c .Base .MsgType = commonpb .MsgType_CreateAlias
48624864 c .Base .SourceID = Params .ProxyCfg .ProxyID
@@ -4874,12 +4876,14 @@ func (c *CreateAliasTask) PreExecute(ctx context.Context) error {
48744876 return nil
48754877}
48764878
4879+ // Execute defines the actual execution of create alias
48774880func (c * CreateAliasTask ) Execute (ctx context.Context ) error {
48784881 var err error
48794882 c .result , err = c .rootCoord .CreateAlias (ctx , c .CreateAliasRequest )
48804883 return err
48814884}
48824885
4886+ // PostExecute defines the post execution, do nothing for create alias
48834887func (c * CreateAliasTask ) PostExecute (ctx context.Context ) error {
48844888 return nil
48854889}
You can’t perform that action at this time.
0 commit comments