Topic proxy terminated. Inform remote Master node that the proxy is gone.
(topicName string)
| 924 | |
| 925 | // Topic proxy terminated. Inform remote Master node that the proxy is gone. |
| 926 | func (c *Cluster) topicProxyGone(topicName string) error { |
| 927 | if c == nil { |
| 928 | // Cluster may be nil due to shutdown. |
| 929 | return nil |
| 930 | } |
| 931 | |
| 932 | // Find the cluster node which owns the topic, then forward to it. |
| 933 | n := c.nodeForTopic(topicName) |
| 934 | if n == nil { |
| 935 | return errors.New("node for topic not found") |
| 936 | } |
| 937 | |
| 938 | req := c.makeClusterReq(ProxyReqLeave, nil, topicName, nil) |
| 939 | req.Gone = true |
| 940 | return n.proxyToMasterAsync(req) |
| 941 | } |
| 942 | |
| 943 | // Returns snowflake worker id. |
| 944 | func clusterInit(configString json.RawMessage, self *string) int { |
no test coverage detected