Module: Searchkick
- Defined in:
- lib/searchkick.rb,
lib/searchkick/index.rb,
lib/searchkick/model.rb,
lib/searchkick/query.rb,
lib/searchkick/indexer.rb,
lib/searchkick/logging.rb,
lib/searchkick/results.rb,
lib/searchkick/version.rb,
lib/searchkick/middleware.rb,
lib/searchkick/index_options.rb,
lib/searchkick/reindex_queue.rb,
lib/searchkick/reindex_v2_job.rb,
lib/searchkick/bulk_reindex_job.rb,
lib/searchkick/process_batch_job.rb,
lib/searchkick/process_queue_job.rb
Defined Under Namespace
Modules: ControllerRuntime, IndexOptions, IndexWithInstrumentation, IndexerWithInstrumentation, Model, QueryWithInstrumentation, SearchkickWithInstrumentation Classes: BulkReindexJob, DangerousOperation, Error, ImportError, Index, Indexer, InvalidQueryError, LogSubscriber, Middleware, MissingIndexError, ProcessBatchJob, ProcessQueueJob, Query, ReindexQueue, ReindexV2Job, Results, UnsupportedVersionError
Constant Summary collapse
- VERSION =
"2.1.1"
Class Attribute Summary collapse
-
.aws_credentials ⇒ Object
Returns the value of attribute aws_credentials.
- .client ⇒ Object
-
.client_options ⇒ Object
Returns the value of attribute client_options.
- .env ⇒ Object
-
.models ⇒ Object
Returns the value of attribute models.
-
.redis ⇒ Object
Returns the value of attribute redis.
-
.search_method_name ⇒ Object
Returns the value of attribute search_method_name.
- .search_timeout ⇒ Object
-
.timeout ⇒ Object
Returns the value of attribute timeout.
-
.wordnet_path ⇒ Object
Returns the value of attribute wordnet_path.
Class Method Summary collapse
- .callbacks(value) ⇒ Object
- .callbacks? ⇒ Boolean
-
.callbacks_value ⇒ Object
private.
-
.callbacks_value=(value) ⇒ Object
private.
- .disable_callbacks ⇒ Object
-
.enable_callbacks ⇒ Object
callbacks.
-
.indexer ⇒ Object
private.
-
.load_records(records, ids) ⇒ Object
private.
- .multi_search(queries) ⇒ Object
- .reindex_status(index_name) ⇒ Object
- .search(term = "*", **options, &block) ⇒ Object
- .server_below?(version) ⇒ Boolean
- .server_version ⇒ Object
- .with_redis ⇒ Object
Class Attribute Details
.aws_credentials ⇒ Object
Returns the value of attribute aws_credentials.
41 42 43 |
# File 'lib/searchkick.rb', line 41 def aws_credentials @aws_credentials end |
.client ⇒ Object
49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 |
# File 'lib/searchkick.rb', line 49 def self.client @client ||= begin require "typhoeus/adapters/faraday" if defined?(Typhoeus) Elasticsearch::Client.new({ url: ENV["ELASTICSEARCH_URL"], transport_options: {request: {timeout: timeout}, headers: {content_type: "application/json"}} }.deep_merge()) do |f| f.use Searchkick::Middleware f.request :aws_signers_v4, { credentials: Aws::Credentials.new(aws_credentials[:access_key_id], aws_credentials[:secret_access_key]), service_name: "es", region: aws_credentials[:region] || "us-east-1" } if aws_credentials end end end |
.client_options ⇒ Object
Returns the value of attribute client_options.
39 40 41 |
# File 'lib/searchkick.rb', line 39 def @client_options end |
.env ⇒ Object
67 68 69 |
# File 'lib/searchkick.rb', line 67 def self.env @env ||= ENV["RAILS_ENV"] || ENV["RACK_ENV"] || "development" end |
.models ⇒ Object
Returns the value of attribute models.
39 40 41 |
# File 'lib/searchkick.rb', line 39 def models @models end |
.redis ⇒ Object
Returns the value of attribute redis.
39 40 41 |
# File 'lib/searchkick.rb', line 39 def redis @redis end |
.search_method_name ⇒ Object
Returns the value of attribute search_method_name.
39 40 41 |
# File 'lib/searchkick.rb', line 39 def search_method_name @search_method_name end |
.search_timeout ⇒ Object
71 72 73 |
# File 'lib/searchkick.rb', line 71 def self.search_timeout @search_timeout || timeout end |
.timeout ⇒ Object
Returns the value of attribute timeout.
39 40 41 |
# File 'lib/searchkick.rb', line 39 def timeout @timeout end |
.wordnet_path ⇒ Object
Returns the value of attribute wordnet_path.
39 40 41 |
# File 'lib/searchkick.rb', line 39 def wordnet_path @wordnet_path end |
Class Method Details
.callbacks(value) ⇒ Object
117 118 119 120 121 122 123 124 125 126 127 128 129 130 |
# File 'lib/searchkick.rb', line 117 def self.callbacks(value) if block_given? previous_value = callbacks_value begin self.callbacks_value = value yield indexer.perform if callbacks_value == :bulk ensure self.callbacks_value = previous_value end else self.callbacks_value = value end end |
.callbacks? ⇒ Boolean
113 114 115 |
# File 'lib/searchkick.rb', line 113 def self.callbacks? Thread.current[:searchkick_callbacks_enabled].nil? || Thread.current[:searchkick_callbacks_enabled] end |
.callbacks_value ⇒ Object
private
185 186 187 |
# File 'lib/searchkick.rb', line 185 def self.callbacks_value Thread.current[:searchkick_callbacks_enabled] end |
.callbacks_value=(value) ⇒ Object
private
190 191 192 |
# File 'lib/searchkick.rb', line 190 def self.callbacks_value=(value) Thread.current[:searchkick_callbacks_enabled] = value end |
.disable_callbacks ⇒ Object
109 110 111 |
# File 'lib/searchkick.rb', line 109 def self.disable_callbacks self.callbacks_value = false end |
.enable_callbacks ⇒ Object
callbacks
105 106 107 |
# File 'lib/searchkick.rb', line 105 def self.enable_callbacks self.callbacks_value = nil end |
.indexer ⇒ Object
private
180 181 182 |
# File 'lib/searchkick.rb', line 180 def self.indexer Thread.current[:searchkick_indexer] ||= Searchkick::Indexer.new end |
.load_records(records, ids) ⇒ Object
private
161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 |
# File 'lib/searchkick.rb', line 161 def self.load_records(records, ids) records = if records.respond_to?(:primary_key) # ActiveRecord records.where(records.primary_key => ids) if records.primary_key elsif records.respond_to?(:queryable) # Mongoid 3+ records.queryable.for_ids(ids) elsif records.respond_to?(:unscoped) && :id.respond_to?(:in) # Nobrainer records.unscoped.where(:id.in => ids) end raise Searchkick::Error, "Not sure how to load records" if !records records end |
.multi_search(queries) ⇒ Object
93 94 95 96 97 98 99 100 101 |
# File 'lib/searchkick.rb', line 93 def self.multi_search(queries) if queries.any? responses = client.msearch(body: queries.flat_map { |q| [q.params.except(:body), q.body] })["responses"] queries.each_with_index do |query, i| query.handle_response(responses[i]) end end queries end |
.reindex_status(index_name) ⇒ Object
138 139 140 141 142 143 144 145 146 |
# File 'lib/searchkick.rb', line 138 def self.reindex_status(index_name) if redis batches_left = Searchkick::Index.new(index_name).batches_left { completed: batches_left == 0, batches_left: batches_left } end end |
.search(term = "*", **options, &block) ⇒ Object
83 84 85 86 87 88 89 90 91 |
# File 'lib/searchkick.rb', line 83 def self.search(term = "*", **, &block) query = Searchkick::Query.new(nil, term, ) block.call(query.body) if block if [:execute] == false query else query.execute end end |
.server_below?(version) ⇒ Boolean
79 80 81 |
# File 'lib/searchkick.rb', line 79 def self.server_below?(version) Gem::Version.new(server_version.sub("-", ".")) < Gem::Version.new(version.sub("-", ".")) end |
.server_version ⇒ Object
75 76 77 |
# File 'lib/searchkick.rb', line 75 def self.server_version @server_version ||= client.info["version"]["number"] end |
.with_redis ⇒ Object
148 149 150 151 152 153 154 155 156 157 158 |
# File 'lib/searchkick.rb', line 148 def self.with_redis if redis if redis.respond_to?(:with) redis.with do |r| yield r end else yield redis end end end |