X-Git-Url: https://gerrit.akraino.org/r/gitweb?a=blobdiff_plain;f=mep%2Fmepserver%2Fmp1%2Fplan_register_svc.go;h=ea5ebff241902ef22144578996ea8bd168435919;hb=a8f10d63cbb6acdc6f9d2f4fa5de3e2392bed6df;hp=2a65de85b4e6c3dd47f5fca2aaf40797ccb069d6;hpb=f60c4a6d3d28aa32d7638a89ec2c3384b4466cb6;p=ealt-edge.git diff --git a/mep/mepserver/mp1/plan_register_svc.go b/mep/mepserver/mp1/plan_register_svc.go index 2a65de8..ea5ebff 100644 --- a/mep/mepserver/mp1/plan_register_svc.go +++ b/mep/mepserver/mp1/plan_register_svc.go @@ -44,6 +44,7 @@ type DecodeRestReq struct { RestBody interface{} `json:"restBody,out"` } +//service request handler func (t *DecodeRestReq) OnRequest(data string) workspace.TaskCode { t.GetParam(t.R) err := t.ParseBody(t.R) @@ -162,6 +163,7 @@ type RegisterServiceInst struct { HttpRsp interface{} `json:"httpRsp,out"` } +//request service registry handling func (t *RegisterServiceInst) OnRequest(data string) workspace.TaskCode { serviceInfo, ok := t.RestBody.(*models.ServiceInfo) if !ok { @@ -172,6 +174,8 @@ func (t *RegisterServiceInst) OnRequest(data string) workspace.TaskCode { serviceInfo.ToRegisterInstance(req) req.Instance.ServiceId = t.ServiceId req.Instance.Properties["appInstanceId"] = t.AppInstanceId + + //Call service comb for instance register resp, err := core.InstanceAPI.Register(t.Ctx, req) if err != nil { log.Errorf(err, "RegisterInstance fail: %s", t.ServiceId)