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 | 24 +++++++++++++++++-------
1 files changed, 17 insertions(+), 7 deletions(-)
diff --git a/pubsub.go b/pubsub.go
index 491ccc2..18f236d 100644
--- a/pubsub.go
+++ b/pubsub.go
@@ -2,27 +2,37 @@
type PubSub interface {
- Publish([]byte)
+ 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" //浜嬩欢娑堟伅
)
-func NewPublisher(url string,mode int) (PubSub,error) {
- return newPub(url)
+func NewPublisher(url string,heartBeatUrl string,mode int) (PubSub,error) {
+ return newPub(url,heartBeatUrl)
}
-func NewSubscriber(url string,mode int,topics []string) (PubSub,error) {
- return newSub(url, topics)
-}
\ No newline at end of file
+//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)
+}
--
Gitblit v1.8.0