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