add example_test.go but can not run , just for how to use

龙赣华

2019-06-03 3a3761054bec493abbc66c75aada07c669f28c8f

add example_test.go but can not run , just for how to use

 example_test.go

New file
@@ -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)
    }
}