From 3a3761054bec493abbc66c75aada07c669f28c8f Mon Sep 17 00:00:00 2001
From: 龙赣华 <slongertian@gmail.com>
Date: 星期一, 03 六月 2019 14:19:26 +0800
Subject: [PATCH] add example_test.go but can not run , just for how to use
---
example_test.go | 101 ++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 101 insertions(+), 0 deletions(-)
diff --git a/example_test.go b/example_test.go
new file mode 100644
index 0000000..4a43cad
--- /dev/null
+++ b/example_test.go
@@ -0,0 +1,101 @@
+package util
+
+import (
+ "fmt"
+
+ "basic.com/pubsub/protomsg.git"
+ "basic.com/r/dbapi.git"
+ "github.com/gogo/protobuf/proto"
+ "github.com/long/test/gopherdiscovery"
+)
+
+/*************************
+* 1. store all struct data
+* 2. define function for get difference data type
+* 3. recive data from sqlite process. and call conpos function.
+***********************/
+
+var camval dbapi.CameraApi
+var taskapi dbapi.TaskApi
+var sdkapi dbapi.SdkApi
+var IsInit bool
+
+var CameraIds []protomsg.Camera
+var CameraTasks []protomsg.CameraAndTaskInfo
+
+var TaskSdks []protomsg.TaskSdkInfo
+var Sdklist []string
+
+//var urlServer = "tcp://192.168.1.11:40007"
+//var urlPubSub = "tcp://192.168.1.11:50007"
+
+var urlServer = "tcp://127.0.0.1:40007"
+var urlPubSub = "tcp://127.0.0.1:50007"
+
+var Sdkflag = make(chan bool)
+var TaskSdkflag = make(chan bool)
+var Cameraflag = make(chan bool)
+
+var newsdkmsg = &protomsg.DbChangeMessage{}
+
+func processinit(initchan chan bool) {
+ CameraIds = camval.FindAll()
+
+ fmt.Println("==============camera camera with task ================")
+ CameraTasks = camval.FindAllCameraAndTask()
+ fmt.Println(CameraTasks)
+
+ TaskSdks = taskapi.FindAll()
+
+ Sdklist = sdkapi.GetAllSdkIds()
+ initchan <- true
+}
+
+func Getdata(opt []byte) {
+ if err := proto.Unmarshal(opt, newsdkmsg); err != nil {
+ fmt.Println("publichshMessage ", err)
+ return
+ }
+
+ switch newsdkmsg.Table {
+ case protomsg.TableChanged_T_Camera:
+ fmt.Println("update camera")
+ CameraIds = camval.FindAll()
+ Cameraflag <- true
+
+ case protomsg.TableChanged_T_CameraTask:
+ fmt.Println("update cameratask")
+ CameraTasks = camval.FindAllCameraAndTask()
+ fmt.Println("update cameratask finished!")
+
+ case protomsg.TableChanged_T_TaskSdk:
+ fmt.Println("update tasksdk")
+ TaskSdks = taskapi.FindAll()
+ TaskSdkflag <- true
+
+ case protomsg.TableChanged_T_Sdk:
+ fmt.Println("update sdk")
+ Sdklist = sdkapi.GetAllSdkIds()
+ go func() {
+ Sdkflag <- true
+ }()
+ fmt.Println("update finished!")
+
+ default:
+ fmt.Println("unknow type operation")
+ }
+ fmt.Println(newsdkmsg)
+}
+
+func Init(initchan chan bool) {
+ clientOne, _ := gopherdiscovery.ClientWithSub(urlServer, urlPubSub, "ip:192.168.1.124")
+ recvinit := clientOne.HeartBeatMsg()
+ fmt.Println(<-recvinit)
+ processinit(initchan)
+
+ peers, _ := clientOne.Peers()
+ for x := range peers {
+ fmt.Println("client: ", string(x))
+ Getdata(x)
+ }
+}
--
Gitblit v1.8.0