func()

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
	}
}