instance update api (#8)

v1/access.go

@@ -47,6 +47,7 @@ func (n *NacosV1Server) AddServiceAccess(ws *restful.WebService) {
 
 func (n *NacosV1Server) addInstanceAccess(ws *restful.WebService) {
 	ws.Route(ws.POST("/instance").To(n.RegisterInstance))
+	ws.Route(ws.PUT("/instance").To(n.UpdateInstance))
 	ws.Route(ws.DELETE("/instance").To(n.DeRegisterInstance))
 	ws.Route(ws.PUT("/instance/beat").To(n.Heartbeat))
 	ws.Route(ws.GET("/instance/list").To(n.ListInstances))
@@ -116,6 +117,28 @@ func (n *NacosV1Server) RegisterInstance(req *restful.Request, rsp *restful.Resp
 	core.WrirteSimpleResponse("ok", http.StatusOK, rsp)
 }
 
+func (n *NacosV1Server) UpdateInstance(req *restful.Request, rsp *restful.Response) {
+	handler := Handler{
+		Request:  req,
+		Response: rsp,
+	}
+
+	namespace := optional(req, model.ParamNamespaceID, model.DefaultNacosNamespace)
+	namespace = model.ToPolarisNamespace(namespace)
+	ins, err := BuildInstance(namespace, req)
+	if err != nil {
+		core.WrirteNacosErrorResponse(err, rsp)
+		return
+	}
+
+	ctx := handler.ParseHeaderContext()
+	if err := n.handleUpdate(ctx, namespace, ins.ServiceName, ins); err != nil {
+		core.WrirteNacosErrorResponse(err, rsp)
+		return
+	}
+	core.WrirteSimpleResponse("ok", http.StatusOK, rsp)
+}
+
 func (n *NacosV1Server) DeRegisterInstance(req *restful.Request, rsp *restful.Response) {
 	handler := Handler{
 		Request:  req,

v1/instance.go

@@ -43,6 +43,18 @@ func (n *NacosV1Server) handleRegister(ctx context.Context, namespace, serviceNa
 	return nil
 }
 
+func (n *NacosV1Server) handleUpdate(ctx context.Context, namespace, serviceName string, ins *model.Instance) error {
+	specIns := model.PrepareSpecInstance(namespace, serviceName, ins)
+	resp := n.discoverSvr.UpdateInstance(ctx, specIns)
+	if apimodel.Code(resp.GetCode().GetValue()) != apimodel.Code_ExecuteSuccess {
+		return &model.NacosError{
+			ErrCode: int32(model.ExceptionCode_ServerError),
+			ErrMsg:  resp.GetInfo().GetValue(),
+		}
+	}
+	return nil
+}
+
 func (n *NacosV1Server) handleDeregister(ctx context.Context, namespace, service string, ins *model.Instance) error {
 	specIns := model.PrepareSpecInstance(namespace, service, ins)
 	resp := n.discoverSvr.DeregisterInstance(ctx, specIns)