Class: Nonnative::FaultInjectionProxy

Inherits:
Proxy
  • Object
show all
Defined in:
lib/nonnative/fault_injection_proxy.rb

Instance Method Summary collapse

Constructor Details

#initialize(service) ⇒ FaultInjectionProxy

Returns a new instance of FaultInjectionProxy.



5
6
7
8
9
10
11
12
 
# File 'lib/nonnative/fault_injection_proxy.rb', line 5

def initialize(service)
  @connections = Concurrent::Hash.new
  @logger = Logger.new(service.proxy.log)
  @mutex = Mutex.new
  @state = :none

  super
end

Instance Method Details

#close_all ⇒ Object 



28
29
30
 
# File 'lib/nonnative/fault_injection_proxy.rb', line 28

def close_all
  apply_state :close_all
end

#delay ⇒ Object 



32
33
34
 
# File 'lib/nonnative/fault_injection_proxy.rb', line 32

def delay
  apply_state :delay
end

#host ⇒ Object 



44
45
46
 
# File 'lib/nonnative/fault_injection_proxy.rb', line 44

def host
  service.proxy.host
end

#invalid_data ⇒ Object 



36
37
38
 
# File 'lib/nonnative/fault_injection_proxy.rb', line 36

def invalid_data
  apply_state :invalid_data
end

#port ⇒ Object 



48
49
50
 
# File 'lib/nonnative/fault_injection_proxy.rb', line 48

def port
  service.proxy.port
end

#reset ⇒ Object 



40
41
42
 
# File 'lib/nonnative/fault_injection_proxy.rb', line 40

def reset
  apply_state :none
end

#start ⇒ Object 



14
15
16
17
18
19
 
# File 'lib/nonnative/fault_injection_proxy.rb', line 14

def start
  @tcp_server = ::TCPServer.new(service.host, service.port)
  @thread = Thread.new { perform_start }

  Nonnative.logger.info "started with host '#{service.host}' and port '#{service.port}' for proxy 'fault_injection'"
end

#stop ⇒ Object 



21
22
23
24
25
26
 
# File 'lib/nonnative/fault_injection_proxy.rb', line 21

def stop
  thread&.terminate
  tcp_server&.close

  Nonnative.logger.info "stopped with host '#{service.host}' and port '#{service.port}' for proxy 'fault_injection'"
end