Class: GearmanAdminClient::Connection

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Includes:
Celluloid::IO
Defined in:
lib/gearman_admin_client/connection.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(address) ⇒ Connection

Returns a new instance of Connection.



15
16
17
 
# File 'lib/gearman_admin_client/connection.rb', line 15

def initialize(address)
  @address = address
end

Instance Attribute Details

#io ⇒ Object (readonly)

Returns the value of attribute io.



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

def io
  @io
end

Instance Method Details

#connect ⇒ Object 



42
43
44
45
46
 
# File 'lib/gearman_admin_client/connection.rb', line 42

def connect
  host, port = @address.split(':')

  @io = TCPSocket.new(host, port)
end

#disconnect ⇒ Object 



48
49
50
51
52
53
 
# File 'lib/gearman_admin_client/connection.rb', line 48

def disconnect
  if @io
    @io.close unless @io.closed?
    @io = nil
  end
end

#disconnected? ⇒ Boolean

Returns:

  • (Boolean) 


55
56
57
 
# File 'lib/gearman_admin_client/connection.rb', line 55

def disconnected?
  @io.nil?
end

#drain ⇒ Object 



31
32
33
34
35
36
37
38
39
40
 
# File 'lib/gearman_admin_client/connection.rb', line 31

def drain
  output = ''

  while line = read
    break if line.chop == '.'
    output << line
  end

  output
end

#read ⇒ Object 



25
26
27
28
29
 
# File 'lib/gearman_admin_client/connection.rb', line 25

def read
  connect if disconnected?

  io.gets
end

#write(command) ⇒ Object 



19
20
21
22
23
 
# File 'lib/gearman_admin_client/connection.rb', line 19

def write(command)
  connect if disconnected?

  io.puts(command)
end