code: func (n *NetworkServerAPI) FlushMulticastQueueForMulticastGroup(ctx context.Context, req *ns.FlushMulticastQueueForMulticastGroupRequest) (*empty.Empty, error) {
  	var mgID uuid.UUID
  	copy(mgID[:], req.MulticastGroupId)
  
  	if err := storage.FlushMulticastQueueForMulticastGroup(storage.DB(), mgID); err != nil {
  		return nil, errToRPCError(err)
  	}
  
  	return &empty.Empty{}, nil
  }
docs: // FlushMulticastQueueForMulticastGroup flushes the multicast device-queue given a multicast-group id.