mangos.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
pubsub.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
mangos.go
@@ -16,7 +16,7 @@ svr *gopherdiscovery.DiscoveryServer cli *gopherdiscovery.DiscoveryClient cliInfo map[string]interface{} cliInfo map[string][]byte recvCh chan Message //recv msg chan } @@ -158,14 +158,14 @@ return ps.recvCh } func (ps *mangosPubSub) GetCliInfo() map[string]interface{} { func (ps *mangosPubSub) GetCliInfo() map[string][]byte { if ps.svr != nil { return ps.cliInfo } return nil } func (ps *mangosPubSub) SetResp(r interface{}) { func (ps *mangosPubSub) SetResp(r []byte) { if ps.cli != nil { ps.cli.SetResp(r) } pubsub.go
@@ -8,9 +8,9 @@ Recv() chan Message GetCliInfo() map[string]interface{} GetCliInfo() map[string][]byte SetResp(interface{}) SetResp([]byte) } type Message struct {