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