name: test ===> taskpubsub

554325746@qq.com

2019-07-24 f7f669143a2429091b362115ae87fd941e076003

 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)