class Sonicsearch::ChannelFactory
Public Instance Methods
close()
click to toggle source
# File lib/sonicsearch.rb, line 30 def close # tcp_clien.send('QUIT') end
connect(mode: nil)
click to toggle source
# File lib/sonicsearch.rb, line 21 def connect(mode: nil) client = Async::IO::Endpoint.tcp('localhost', 1491) client.connect do |peer| result = peer.write("START #{mode} password") message = peer.read(512) puts "Sent #{data}, got response: #{message}" end end
control_channel()
click to toggle source
# File lib/sonicsearch.rb, line 17 def control_channel connect(mode: 'control') end
ingest_channel()
click to toggle source
# File lib/sonicsearch.rb, line 13 def ingest_channel connect(mode: 'ingest') end
search_channel()
click to toggle source
# File lib/sonicsearch.rb, line 9 def search_channel connect(mode: 'search') end