package controllers
|
|
import (
|
"basic.com/valib/bhomeclient.git"
|
"basic.com/valib/logger.git"
|
"vamicro/system-service/serf"
|
)
|
|
type ProxySync struct {
|
}
|
|
/**
|
代理支持所有应用广播同步消息到serf集群中
|
*/
|
func (ps *ProxySync) Sync(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
type PSyncVo struct {
|
Body string `json:"body"`
|
}
|
var reqBody PSyncVo
|
err := c.BindJSON(&reqBody)
|
if err != nil {
|
return &bhomeclient.Reply{Msg: err.Error()}
|
}
|
err = serf.SyncProxy(serf.DataSystemSerfSubscribe, []byte(reqBody.Body))
|
if err != nil {
|
logger.Error("SyncProxy err:", err)
|
return &bhomeclient.Reply{Msg: err.Error()}
|
}
|
return &bhomeclient.Reply{Success: true, Msg: "同步成功"}
|
}
|
