From 0c9642be9fb9ed7efa5330d67551bb78b47e0d10 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期四, 12 三月 2020 12:17:02 +0800
Subject: [PATCH] use []byte replate interface
---
pubsub.go | 13 +++++++++++--
1 files changed, 11 insertions(+), 2 deletions(-)
diff --git a/pubsub.go b/pubsub.go
index fa41d64..18f236d 100644
--- a/pubsub.go
+++ b/pubsub.go
@@ -4,18 +4,27 @@
Publish(Message)
+ Surveyor() []string
+
Recv() chan Message
+
+ GetCliInfo() map[string][]byte
+
+ SetResp([]byte)
}
type Message struct {
+ Id string
Topic string
Msg []byte
}
const (
- Topic_Camera = "camera" //鎽勫儚鏈烘秷鎭�
+ Topic_Camera = "camera" //鎽勫儚鏈鸿В鐮佹秷鎭�
+ Topic_StackDecode = "stackDecode" //鏁版嵁鏍堣В鐮佹秷鎭�
Topic_Task = "task" //浠诲姟娑堟伅
Topic_Sdk = "sdk" //绠楁硶娑堟伅
+ Topic_RuleProc = "ruleProcess" //ruleProcess娑堟伅
Topic_Event = "event" //浜嬩欢娑堟伅
)
@@ -26,4 +35,4 @@
//processId is process Identifier,unique
func NewSubscriber(url string,heartBeatUrl string,mode int,topics []string,processId string) (PubSub,error) {
return newSub(url,heartBeatUrl, topics, processId)
-}
\ No newline at end of file
+}
--
Gitblit v1.8.0