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