lib/elasticsearch/api/actions/bulk.rb in elasticsearch-api-0.4.1 vs lib/elasticsearch/api/actions/bulk.rb in elasticsearch-api-0.4.2

- old
+ new

@@ -31,27 +31,30 @@ # params: { value: 42 }, upsert: { counter: 0 } } # }} # # ] # - # @option arguments [String] :index Default index for items which don't provide one - # @option arguments [String] :type Default document type for items which don't provide one + # @option arguments [String] :index Default index for items which don't provide one + # @option arguments [String] :type Default document type for items which don't provide one # @option arguments [Array<Hash>] :body An array of operations to perform, each operation is a Hash - # @option arguments [String] :consistency Explicit write consistency setting for the operation (options: one, quorum, all) + # @option arguments [String] :consistency Explicit write consistency setting for the operation + # (options: one, quorum, all) # @option arguments [Boolean] :refresh Refresh the index after performing the operation - # @option arguments [String] :replication Explicitely set the replication type (options: sync, async) - # @option arguments [String] :type Default document type for items which don't provide one + # @option arguments [String] :replication Explicitely set the replication type (options: sync, async) + # @option arguments [String] :type Default document type for items which don't provide one + # @option arguments [Time] :timeout Explicit operation timeout # # @return [Hash] Deserialized Elasticsearch response # # @see http://elasticsearch.org/guide/reference/api/bulk/ # def bulk(arguments={}) valid_params = [ :consistency, :refresh, :replication, - :type ] + :type, + :timeout ] method = 'POST' path = Utils.__pathify Utils.__escape(arguments[:index]), Utils.__escape(arguments[:type]), '_bulk' params = Utils.__validate_and_extract_params arguments, valid_params