Class: Sonicsearch::ChannelFactory

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

Instance Method Summary collapse

Instance Method Details

#close ⇒ Object 



30
31
32
 
# File 'lib/sonicsearch.rb', line 30

def close
  # tcp_clien.send('QUIT')
end

#connect(mode: nil) ⇒ Object 



21
22
23
24
25
26
27
28
 
# 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 ⇒ Object 



17
18
19
 
# File 'lib/sonicsearch.rb', line 17

def control_channel
  connect(mode: 'control')
end

#ingest_channel ⇒ Object 



13
14
15
 
# File 'lib/sonicsearch.rb', line 13

def ingest_channel
  connect(mode: 'ingest')
end

#search_channel ⇒ Object 



9
10
11
 
# File 'lib/sonicsearch.rb', line 9

def search_channel
  connect(mode: 'search')
end