class ProfileCollection
Public Class Methods
new(documents, parser, generate_id)
click to toggle source
# File lib/logstash/inputs/mongoprofile.rb, line 87 def initialize(documents, parser, generate_id) @generate_id = generate_id @documents = [] documents.each do |document| @documents.push(document) end @parser = parser end
Public Instance Methods
each() { |parse| ... }
click to toggle source
# File lib/logstash/inputs/mongoprofile.rb, line 98 def each @documents.each do |document| if @generate_id document['_id'] = generate_id.to_s end yield @parser.parse(document) end @documents = [] end
get_last_document_date()
click to toggle source
# File lib/logstash/inputs/mongoprofile.rb, line 110 def get_last_document_date if @documents != nil and @documents[-1] != nil @documents[-1]['ts'] else nil end end
length()
click to toggle source
# File lib/logstash/test.rb, line 89 def length @documents.length end
Private Instance Methods
generate_id()
click to toggle source
# File lib/logstash/inputs/mongoprofile.rb, line 119 def generate_id # noinspection RubyArgCount BSON::ObjectId.new end