Class: Sonicsearch::Ingest

Inherits:
Object
  • Object
show all
Defined in:
lib/sonicsearch/ingest.rb

Instance Method Summary collapse

Instance Method Details

#connection ⇒ Object 



47
48
49
 
# File 'lib/sonicsearch/ingest.rb', line 47

def connection
  ChannelFactory.new.ingest_channel
end

#count(collection_id, bucket_id, object_id) ⇒ Object 



19
20
21
22
23
24
 
# 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) ⇒ Object 



33
34
35
36
37
38
 
# 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) ⇒ Object 



26
27
28
29
30
31
 
# 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) ⇒ Object 



40
41
42
43
44
45
 
# 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) ⇒ Object 



12
13
14
15
16
17
 
# 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) ⇒ Object 



5
6
7
8
9
10
 
# 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