Class: MKIt::DockerListener

Inherits:
Object
  • Object
show all
Includes:
DockerHelper
Defined in:
lib/mkit/docker_listener.rb

Instance Method Summary collapse

Methods included from DockerHelper

#attach_network, #create_instance, #create_network, #create_volume, #delete_volume, #dettach_network, #execute_local, #inspect_instance, #inspect_volume, #logs, #network_exists?, #remove_instance, #remove_network, #start_instance, #stop_instance

Constructor Details

#initialize ⇒ DockerListener

Returns a new instance of DockerListener.



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

def initialize
  @queue = Queue.new
end

Instance Method Details

#enqueue(msg) ⇒ Object 



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

def enqueue(msg)
  @queue << msg
end

#start ⇒ Object 



21
22
23
24
 
# File 'lib/mkit/docker_listener.rb', line 21

def start
  @consumer.run if register_consumer
  @listener.run if register_listener
end

#stop ⇒ Object 



26
27
28
29
30
 
# File 'lib/mkit/docker_listener.rb', line 26

def stop
  @listener.exit if @listener
  @consumer.raise StopThread.new
  MKItLogger.info("docker listener stopped")
end