func (f *Fetcher) enqueue(peer string, events inter.Events, time time.Time, fetchEvents EventsRequesterFn) error {
    // divide big batch into smaller ones
    for start := 0; start < len(events); start += maxInjectBatch {
        end := len(events)
        if end > start+maxInjectBatch {