code: func FlushMulticastQueueForMulticastGroup(db sqlx.Execer, multicastGroupID uuid.UUID) error {
  	_, err := db.Exec(`
  		delete from
  			multicast_queue
  		where
  			multicast_group_id = $1
  	`, multicastGroupID)
  	if err != nil {
  		return handlePSQLError(err, "delete error")
  	}
  
  	log.WithFields(log.Fields{
  		"multicast_group_id": multicastGroupID,
  	}).Info("multicast-group queue flushed")
  
  	return nil
  }
docs: // FlushMulticastQueueForMulticastGroup flushes the multicast-queue given
  // a multicast-group id.