code: func (s *DataMsgServiceServer) DataResyncs(ctx context.Context, req *msg.DataResyncRequests) (
  	*msg.DataResyncReplies, error) {
  	resyncs := req.GetDataResyncs()
  	if resyncs != nil {
  		//TODO propagate event like in Kafka transport
  
  		/*localtxn := syncbase.NewLocalBytesTxn(s.adapter.localtransp.PropagateBytesResync)
  		if len(resyncs) == 0 {
  			log.Debug("received empty resync => DELETE ALL")
  		}
  		for _, chReq := range resyncs {
  			//TODO chReq.ContentType
  			localtxn.Put(chReq.Key, chReq.Content)
  		}
  		err := localtxn.Commit()*/
  		var err error
  		if err != nil {
  			return &msg.DataResyncReplies{MsgId: replySeq(), Error: &msg.Error{Message: err.Error()} /*TODO all other fields*/}, err
  		}
  
  		return &msg.DataResyncReplies{MsgId: replySeq() /*TODO all other fields*/}, nil
  	}
  
  	err := errors.New("unexpected place - nil resyncs")
  	return &msg.DataResyncReplies{MsgId: replySeq(), Error: &msg.Error{Message: err.Error()} /*TODO all other fields*/}, err
  }
docs: // DataResyncs propagates the events in the stream to go channels of registered plugins.