From 3c8609a3da72cb2f3610f3f1789dafacc6c0f40f Mon Sep 17 00:00:00 2001
From: 龙赣华 <slongertian@gmail.com>
Date: 星期五, 31 五月 2019 11:13:58 +0800
Subject: [PATCH] add heartbeat
---
tasktag/tasktag.go | 33 +++++++++++++++------------------
1 files changed, 15 insertions(+), 18 deletions(-)
diff --git a/tasktag/tasktag.go b/tasktag/tasktag.go
index 0bc06ce..87b0835 100644
--- a/tasktag/tasktag.go
+++ b/tasktag/tasktag.go
@@ -2,30 +2,27 @@
import (
"fmt"
+
"basic.com/pubsub/protomsg.git"
- "basic.com/dbapi.git"
+ "github.com/long/test/util"
)
-var TaskMapLab = make(map[string] *protomsg.TaskLabel)
-var taskapi dbapi.TaskApi
+var TaskMapLab = make(map[string]*protomsg.TaskLabel)
func Init() {
- fmt.Println("=========== tasktag info ====================")
var tls []protomsg.TaskLabel
+ fmt.Println("============= init tasktag info =====================")
- taskSdks := taskapi.FindAll()
- for _, taskSdk := range taskSdks {
- fmt.Println("test: ", taskSdk)
- var tl protomsg.TaskLabel
- tl.Taskid = taskSdk.Task.Taskid
- for _, sdkinfo := range taskSdk.Sdks {
- tl.Sdkids = append(tl.Sdkids, sdkinfo.Id)
- }
- fmt.Println(tl)
- tl.Index=int32(0)
- tls = append(tls, tl)
- }
+ for _, taskSdk := range util.TaskSdks {
+ var tl protomsg.TaskLabel
+ tl.Taskid = taskSdk.Task.Taskid
+ for _, sdkinfo := range taskSdk.Sdks {
+ tl.Sdkids = append(tl.Sdkids, sdkinfo.Id)
+ }
+ tl.Index = int32(0)
+ tls = append(tls, tl)
+ }
GenTasklab(tls)
@@ -39,7 +36,7 @@
//浠� taskid 浣滀负key, 瀵瑰簲鐨勭畻娉曠粍鍚堜綔涓� value
func GenTasklab(tasklab []protomsg.TaskLabel) {
for _, value := range tasklab {
- pv := value
- TaskMapLab[value.Taskid] = &pv
+ pv := value
+ TaskMapLab[value.Taskid] = &pv
}
}
--
Gitblit v1.8.0