lib/logstash/inputs/google_cloud_storage.rb
def list_processable_blobs
    @logger.info("Fetching blobs from #{@bucket_id}")
    @client.list_blobs do |blob|
      yield blob if @blob_filter.should_process?(blob)
    end
  end
# list_processable_blobs will list blobs in the bucket and yield them if they are not filtered
list_processable_blobs will list blobs in the bucket and yield them if they are not filtered
list_processable_blobs will list blobs in the bucket and yield them if they are not filtered
def list_processable_blobs
    @logger.info("Fetching blobs from #{@bucket_id}")
    @client.list_blobs do |blob|
      yield blob if @blob_filter.should_process?(blob)
    end
  end
def list_processable_blobs @logger . info ( "Fetching blobs from #{@bucket_id}" ) @client . list_blobs do | blob | yield blob if @blob_filter . should_process? ( blob ) end end
list_processable_blobs will list blobs in the bucket and yield them if they are not filtered
list_processable_blobs will list blobs in the bucket and yield them if they are not filtered