ee/lib/gitlab/geo/log_cursor/event_logs.rb
# fetches up to BATCH_SIZE next events and keep track of batches
fetches up to BATCH_SIZE next events and keep track of batches
fetches up to BATCH_SIZE next events and keep track of batches
def fetch_in_batches(batch_size: BATCH_SIZE)
          ::Geo::EventLog.where('id > ?', last_processed).find_in_batches(batch_size: batch_size) do |batch|
            yield batch
            save_processed(batch.last.id)
            break unless Lease.renew!
          end
        end
def fetch_in_batches ( batch_size : BATCH_SIZE ) :: Geo :: EventLog . where ( 'id > ?' , last_processed ) . find_in_batches ( batch_size : batch_size ) do | batch | yield batch save_processed ( batch . last . id ) break unless Lease . renew! end end
fetches up to BATCH_SIZE next events and keep track of batches
fetches up to BATCH_SIZE next events and keep track of batches
batch_size
<not_specific>