Method: SolrUtil#update_core_request

Defined in:
lib/fluent/plugin/solr_util.rb

#update_core_request(documents) ⇒ Object 



25
26
27
28
29
30
31
32
33
 
# File 'lib/fluent/plugin/solr_util.rb', line 25

def update_core_request(documents)
  http = Net::HTTP.new(@host, @port.to_i)
  http.read_timeout = @read_timeout
  url = '/solr/' + URI.escape(core) + '/update'
  url += '?commit=true' if @commit
  request = Net::HTTP::Post.new(url, 'content-type' => 'application/json; charset=utf-8')
  request.body = Yajl::Encoder.encode(documents)
  http.request(request).value
end