The gopush-cluster 's scala port