proxyToMaster forwards request from topic proxy to topic master.
(msg *ClusterReq)
| 384 | |
| 385 | // proxyToMaster forwards request from topic proxy to topic master. |
| 386 | func (n *ClusterNode) proxyToMaster(msg *ClusterReq) error { |
| 387 | msg.Node = globals.cluster.thisNodeName |
| 388 | var rejected bool |
| 389 | err := n.call("Cluster.TopicMaster", msg, &rejected) |
| 390 | if err == nil && rejected { |
| 391 | err = errors.New("cluster: topic master node out of sync") |
| 392 | } |
| 393 | return err |
| 394 | } |
| 395 | |
| 396 | // proxyToMaster forwards request from topic proxy to topic master. |
| 397 | func (n *ClusterNode) proxyToMasterAsync(msg *ClusterReq) error { |