class LogStash::Outputs::Elasticsearch::Protocols::NodeClient

def self.normalize_bulk_response(bulk_response)
  # TODO(talevy): parse item response objects to retrieve correct 200 (OK) or 201(created) status codes
  if bulk_response.has_failures()
    {"errors" => true,
     "statuses" => bulk_response.map { |i| (i.is_failed && i.get_failure.get_status.get_status) || 200 }}
  else
    {"errors" => false}
  end
end