Class: MKIt::DockerLogListener

Inherits:
ShellClient show all
Defined in:
lib/mkit/pods/docker_log_listener.rb

Instance Method Summary collapse

Methods inherited from ShellClient

#unregister

Constructor Details

#initialize(pod, ws, options: {}) ⇒ DockerLogListener

Returns a new instance of DockerLogListener.



6
7
8
9
10
11
12
13
14
15
 
# File 'lib/mkit/pods/docker_log_listener.rb', line 6

def initialize(pod, ws, options: {})
  @pod = pod
  @ws = ws
  command = "docker logs"
  command += " -f" if options[:follow] == 'true'
  command += " -n #{options[:nr_lines]}" if options[:nr_lines]
  command += " -n 10" unless options[:nr_lines]
  command += " #{@pod.name}"
  super(command: command)
end

Instance Method Details

#close ⇒ Object 



25
26
27
 
# File 'lib/mkit/pods/docker_log_listener.rb', line 25

def close
  @ws.close_websocket unless @ws.nil?
end

#register ⇒ Object 



17
18
19
20
21
22
23
 
# File 'lib/mkit/pods/docker_log_listener.rb', line 17

def register
  super do |stdout, stdin, pid|
    stdout.each {
      |line| @ws.send(line.strip!)
    }
  end
end