Method proxyToMasterAsync

server/cluster.go:397–412

proxyToMaster forwards request from topic proxy to topic master.

(msg *ClusterReq)

// proxyToMaster forwards request from topic proxy to topic master.
func (n *ClusterNode) proxyToMasterAsync(msg *ClusterReq) error {
	select {
	case n.p2mSender <- msg:
		return nil
	default:
	}
	// Buffer is full. Wait briefly before giving up.
	timer := time.NewTimer(clusterP2MTimeout)
	defer timer.Stop()
	select {
	case n.p2mSender <- msg:
		return nil
	case <-timer.C:
		return errors.New("cluster: load exceeded")
	}
}

// masterToProxyAsync forwards response from topic master to topic proxy
// in a fire-and-forget manner.