def createGenerator(label, options, index=None):
    cid = label
    if index:
        cid += "_" + str(index)
    msg_gen = GaussianSize(cid, options.msg_count, options.msg_size)
    if options.timing:
        msg_gen = TimeTracking(msg_gen)
    if options.msgs_per_second > 0:
        if options.jitter > 0:
            msg_gen = JitteryRateLimited(msg_gen,
                                         options.msgs_per_second,
                                         options.jitter)
        else:
            msg_gen = RateLimited(msg_gen, options.msgs_per_second)
    return msg_gen
iterate over alignments by query
dataset/ETHPy150Open remakeelectric/mqtt-malaria/beem/msgs.py/createGenerator--crossover with--dataset/ETHPy150Open CGATOxford/cgat/CGAT/Diamond.py/query_iterator