Skip to content

A
ai-api-mgr
Commit 1b3fb251 authored by Your Name's avatar Your Name
Browse files
Options

add workload public to kafka

parent b3cbf474
Hide whitespace changes
Inline Side-by-side
Showing with 12 additions and 10 deletions
main.go
View file @ 1b3fb251
...@@ -548,16 +548,18 @@ func ApiAndJWT(c *fiber.Ctx) error { ...@@ -548,16 +548,18 @@ func ApiAndJWT(c *fiber.Ctx) error {
cmd = task.Cmd cmd = task.Cmd
pbMsg := pbUpstream.TaskContent{ pbMsg := pbUpstream.TaskContent{
TaskUuid: reqHeaders["Task-Id"][0], TaskUuid: reqHeaders["Task-Id"][0],
TaskId: uint64(task.ID), TaskId: uint64(task.ID),
TaskType: 1, TaskType: 1,
TaskCmd: cmd, TaskCmd: cmd,
TaskParam: c.Body(), //[]byte(reqHeaders["Task-Id"][0]), TaskParam: c.Body(), //[]byte(reqHeaders["Task-Id"][0]),
TaskTimestamp: uint64(time.Now().UnixNano()), TaskTimestamp: uint64(time.Now().UnixNano()),
TaskCallback: "http://" + callbackAddr + "/callback/v1", //"http://192.168.1.10:6001/callback/v1", TaskCallback: "http://" + callbackAddr + "/callback/v1", //"http://192.168.1.10:6001/callback/v1",
TaskUid: reqHeaders["X-Consumer-Custom-Id"][0], TaskUid: reqHeaders["X-Consumer-Custom-Id"][0],
TaskFee: fmt.Sprintf("%d", task.Price), TaskFee: fmt.Sprintf("%d", task.Price),
TaskInLen: int32(len(c.Body())), TaskInLen: int32(len(c.Body())),
TaskWorkload: task.Workload,
ContainerPubkey: []byte(task.PublicKey),
} }
msgAsJson, err := json.Marshal(pbMsg) msgAsJson, err := json.Marshal(pbMsg)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment