code: func (p *pullMediatorImpl) Add(msg *proto.SignedGossipMessage) {
  	p.Lock()
  	defer p.Unlock()
  	itemID := p.IdExtractor(msg)
  	p.itemID2Msg[itemID] = msg
  	p.engine.Add(itemID)
  	p.logger.Debugf("Added %s, total items: %d", itemID, len(p.itemID2Msg))
  }
docs: // Add adds a GossipMessage to the store