in api/datanode/datanode.go [102:114]
func (dnClient *DatanodeClient) RaftReceiver() {
for {
proto, err := (*dnClient.ratisClient).Recv()
if err == io.EOF {
return
}
if err != nil {
fmt.Println(err)
return
}
dnClient.ratisReceiver <- *proto
}
}