feat: update response definition to match nerveX components

examples/nervex-mock-agconfig.yaml

@@ -8,7 +8,7 @@ spec:
       spec:
         containers:
         - name: aggregator
-          image: registry.sensetime.com/cloudnative4ai/nervex-mock:v0.0.4
+          image: registry.sensetime.com/cloudnative4ai/nervex-mock:v0.0.5
           imagePullPolicy: IfNotPresent
           command: ["/bin/bash", "-c",]
           args: ["until ping -c 1 $HOSTNAME.default ; do sleep 1 ; done ; sleep 5; python3 -u main.py aggregator -sl $HOSTNAME.default -sp $AGGREGATOR_PORT -sl $HOSTNAME.default -ml $HOSTNAME.default -mp 81"]

examples/nervex-mock-nervexjob.yaml

@@ -10,8 +10,8 @@ spec:
       spec:
         containers:
         - name: coordinator
-          image: registry.sensetime.com/cloudnative4ai/nervex-mock:v0.0.4
-          imagePullPolicy: IfNotPresent
+          image: registry.sensetime.com/cloudnative4ai/nervex-mock:v0.0.5
+          imagePullPolicy: Always
           command: ["/bin/bash", "-c",]
           args: ["python3 -u main.py coordinator -l $HOSTNAME -p $COORDINATOR_PORT"]
           # args: ["sleep 3600"]
@@ -20,10 +20,10 @@ spec:
       spec:
         containers:
         - name: collector
-          image: registry.sensetime.com/cloudnative4ai/nervex-mock:v0.0.4
-          imagePullPolicy: IfNotPresent
+          image: registry.sensetime.com/cloudnative4ai/nervex-mock:v0.0.5
+          imagePullPolicy: Always
           command: ["/bin/bash", "-c",]
-          args: ["until ping -c 1 $HOSTNAME.default ; do sleep 1 ; done ; sleep 5; python3 -u main.py actor -l $HOSTNAME.default -p $ACTOR_PORT"]
+          args: ["until ping -c 1 $HOSTNAME.default ; do sleep 1 ; done ; sleep 10; python3 -u main.py collector -l $HOSTNAME.default -p $COLLECTOR_PORT"]
           ports:
           - name: collector
             containerPort: 80
@@ -32,10 +32,10 @@ spec:
       spec:
         containers:
         - name: learner
-          image: registry.sensetime.com/cloudnative4ai/nervex-mock:v0.0.4
-          imagePullPolicy: IfNotPresent
+          image: registry.sensetime.com/cloudnative4ai/nervex-mock:v0.0.5
+          imagePullPolicy: Always
           command: ["/bin/bash", "-c",]
-          args: ["until ping -c 1 $HOSTNAME.default ; do sleep 1 ; done ; sleep 5; python3 -u main.py learner -l $HOSTNAME.default -p $LEARNER_PORT"]
+          args: ["until ping -c 1 $HOSTNAME.default ; do sleep 1 ; done ; sleep 10; python3 -u main.py learner -l $HOSTNAME.default -p $LEARNER_PORT"]
           ports:
           - name: learner
             containerPort: 80

server/http/server.go

@@ -42,29 +42,32 @@ func (s *NerveXServer) Replicas(w http.ResponseWriter, r *http.Request) {
 	var reps interface{}
 	var err error
 	var msg string
+
+	// handle request by request method
 	switch r.Method {
 	case "GET":
 		msg = "successfully get replicas"
 		reps, err = s.getReplicas(r)
-		if err != nil {
-			msg = err.Error()
-		}
 	case "POST":
 		msg = "successfully create replicas"
 		reps, err = s.addReplicas(r)
-		if err != nil {
-			msg = err.Error()
-		}
 	case "DELETE":
 		msg = "successfully delete replicas"
 		reps, err = s.deleteReplicas(r)
-		if err != nil {
-			msg = err.Error()
-		}
 	}
 
+	var success bool = true
+	var code int = CODE_SUCCESS
+	if err != nil {
+		success = false
+		code = CODE_FAILED
+		msg = err.Error()
+	}
+
+	// build response
 	rep := Response{
-		Status:  StatusOK,
+		Success: success,
+		Code:    code,
 		Message: msg,
 		Data:    reps,
 	}

server/http/types.go

@@ -43,14 +43,15 @@ type ResourceQuantity struct {
 }
 
 type Response struct {
-	Status  string      `json:"status"`
+	Success bool        `json:"success"`
+	Code    int         `json:"code"`
 	Message string      `json:"message"`
 	Data    interface{} `json:"data"`
 }
 
 const (
-	StatusOK     = "OK"
-	StatusFailed = "Failed"
+	CODE_SUCCESS = iota
+	CODE_FAILED
 )
 
 type NerveXJobResponse struct {