class Sonicsearch::Ingest
Public Instance Methods
connection()
click to toggle source
# File lib/sonicsearch/ingest.rb, line 47 def connection ChannelFactory.new.ingest_channel end
count(collection_id, bucket_id, object_id)
click to toggle source
# File lib/sonicsearch/ingest.rb, line 19 def count(collection_id, bucket_id, object_id) cmd = "COUNT #{collection_id} #{bucket_id} #{object_id} #{text}" connection.connect do |peer| peer.write(cmd) end end
flushb(collection_id, _bucket_id)
click to toggle source
# File lib/sonicsearch/ingest.rb, line 33 def flushb(collection_id, _bucket_id) cmd = "FLUSHB #{collection_id}" connection.connect do |peer| peer.write(cmd) end end
flushc(collection_id)
click to toggle source
# File lib/sonicsearch/ingest.rb, line 26 def flushc(collection_id) cmd = "FLUSHC #{collection_id}" connection.connect do |peer| peer.write(cmd) end end
flusho(collection_id, _bucket_id, _object_id)
click to toggle source
# File lib/sonicsearch/ingest.rb, line 40 def flusho(collection_id, _bucket_id, _object_id) cmd = "FLUSHO #{collection_id}" connection.connect do |peer| peer.write(cmd) end end
pop(collection_id, bucket_id, object_id, text)
click to toggle source
# File lib/sonicsearch/ingest.rb, line 12 def pop(collection_id, bucket_id, object_id, text) cmd = "POP #{collection_id} #{bucket_id} #{object_id} #{text}" connection.connect do |peer| peer.write(cmd) end end
push(collection_id, bucket_id, object_id, text)
click to toggle source
# File lib/sonicsearch/ingest.rb, line 5 def push(collection_id, bucket_id, object_id, text) cmd = "PUSH #{collection_id} #{bucket_id} #{object_id} #{text}" connection.connect do |peer| peer.write(cmd) end end