From f7f669143a2429091b362115ae87fd941e076003 Mon Sep 17 00:00:00 2001
From: 554325746@qq.com <554325746@qq.com>
Date: 星期三, 24 七月 2019 14:21:37 +0800
Subject: [PATCH] name: test ===> taskpubsub
---
sdk/sdk.go | 19 +++++++++++++++----
1 files changed, 15 insertions(+), 4 deletions(-)
diff --git a/sdk/sdk.go b/sdk/sdk.go
index e8bce98..2075e35 100644
--- a/sdk/sdk.go
+++ b/sdk/sdk.go
@@ -5,14 +5,14 @@
"errors"
"fmt"
- // "github.com/long/test/httpclient"
- "github.com/long/test/tasktag"
- "github.com/long/test/util"
+ // "github.com/long/taskpubsub/httpclient"
+ "github.com/long/taskpubsub/tasktag"
+ "github.com/long/taskpubsub/util"
"github.com/gogo/protobuf/proto"
"basic.com/pubsub/protomsg.git"
"basic.com/valib/deliver.git"
- "github.com/long/test/logger"
+ "github.com/long/taskpubsub/logger"
)
const (
@@ -38,9 +38,16 @@
}
// 鎵嬪姩杈撳叆鐨勪富棰�
+
+ // sdk-no-track
+ CreatesdkTopicandServer("facedetect-sdk-no-track")
+ logger.Info()
+
+ // es
SdkMap["es"] = make(chan protomsg.SdkMessage)
logger.Info("create es channel: ")
+ // web
SdkMap["virtual-faceextract-sdk-pull"] = make(chan protomsg.SdkMessage)
logger.Info("create virtual-faceextract-sdk-pull")
@@ -117,8 +124,12 @@
for key, _ := range SdkMap {
oldSdk = append(oldSdk, key)
}
+
+ // 鎵嬪姩娣诲姞鐨勫叏閮ㄥ姞涓�
util.Sdklist = append(util.Sdklist, "es")
util.Sdklist = append(util.Sdklist, "virtual-faceextract-sdk-pull")
+ util.Sdklist = append(util.Sdklist, "facedetect-sdk-no-track")
+
sdkChanDel := util.Difference(oldSdk, util.Sdklist)
logger.Info(sdkChanDel)
--
Gitblit v1.8.0