package service
|
|
import (
|
"basic.com/valib/deliver.git"
|
"github.com/gin-gonic/gin/internal/json"
|
)
|
|
type ImageSource struct {
|
Id string `json:"id"`
|
Data []byte `json:"data"`
|
}
|
const (
|
Url_Service_PUSH = "tcp:///tmp///webserver-2.ipc"
|
Url_Service_PULL = "tcp:///tmp///webserver-1.ipc"
|
)
|
var imgChan chan ImageSource
|
func PushImgMsg(is ImageSource){
|
imgChan <- is
|
}
|
|
func InitService(){
|
imgChan = make(chan ImageSource)
|
client := deliver.NewClient(deliver.PushPull, Url_Service_PUSH)
|
for {
|
select {
|
case is := <- imgChan:
|
b, _ := json.Marshal(is)
|
client.Send(b)
|
}
|
|
|
}
|
|
}
|
