Class: ReceptorController::Client::Configuration

Inherits:
Object
  • Object
show all
Defined in:
lib/receptor_controller/client/configuration.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize {|_self| ... } ⇒ Configuration

Returns a new instance of Configuration.

Yields:

  • (_self)

Yield Parameters:



34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'lib/receptor_controller/client/configuration.rb', line 34

def initialize
  @controller_scheme = 'http'
  @controller_host   = 'localhost:9090'

  @connection_status_path = '/connection/status'
  @job_path               = '/job'
  @pre_shared_key         = nil

  @queue_auto_ack    = true
  @queue_host        = nil
  @queue_max_bytes   = nil
  @queue_persist_ref = "receptor-client.#{SecureRandom.uuid}"
  @queue_port        = nil
  @queue_topic       = 'platform.receptor-controller.responses'

  @response_timeout           = 2.minutes
  @response_timeout_poll_time = 10.seconds # TODO: use Concurrent::TimerTask

  yield(self) if block_given?
end

Instance Attribute Details

#connection_status_path ⇒ Object

Path to connection status requests



9
10
11
 
# File 'lib/receptor_controller/client/configuration.rb', line 9

def connection_status_path
  @connection_status_path
end

#controller_host ⇒ Object

Host name of cloud receptor controller



6
7
8
 
# File 'lib/receptor_controller/client/configuration.rb', line 6

def controller_host
  @controller_host
end

#controller_scheme ⇒ Object

Scheme of cloud receptor controller



4
5
6
 
# File 'lib/receptor_controller/client/configuration.rb', line 4

def controller_scheme
  @controller_scheme
end

#job_path ⇒ Object

Path to sending directive requests



11
12
13
 
# File 'lib/receptor_controller/client/configuration.rb', line 11

def job_path
  @job_path
end

#pre_shared_key ⇒ Object

x-rh-rbac-psk header for authentication with receptor controller (replaces x-rh-identity)



14
15
16
 
# File 'lib/receptor_controller/client/configuration.rb', line 14

def pre_shared_key
  @pre_shared_key
end

#queue_auto_ack ⇒ Object

Kafka message auto-ack (default false)



17
18
19
 
# File 'lib/receptor_controller/client/configuration.rb', line 17

def queue_auto_ack
  @queue_auto_ack
end

#queue_host ⇒ Object

Kafka host name



19
20
21
 
# File 'lib/receptor_controller/client/configuration.rb', line 19

def queue_host
  @queue_host
end

#queue_max_bytes ⇒ Object

Kafka topic max bytes received in one response



21
22
23
 
# File 'lib/receptor_controller/client/configuration.rb', line 21

def queue_max_bytes
  @queue_max_bytes
end

#queue_persist_ref ⇒ Object

Kafka topic grouping (if nil, all subscribes receives all messages)



23
24
25
 
# File 'lib/receptor_controller/client/configuration.rb', line 23

def queue_persist_ref
  @queue_persist_ref
end

#queue_port ⇒ Object

Kafka port



25
26
27
 
# File 'lib/receptor_controller/client/configuration.rb', line 25

def queue_port
  @queue_port
end

#queue_topic ⇒ Object

Kafka topic name for cloud receptor controller’s responses



27
28
29
 
# File 'lib/receptor_controller/client/configuration.rb', line 27

def queue_topic
  @queue_topic
end

#response_timeout ⇒ Object

Timeout for how long successful request waits for response



30
31
32
 
# File 'lib/receptor_controller/client/configuration.rb', line 30

def response_timeout
  @response_timeout
end

#response_timeout_poll_time ⇒ Object

Interval between timeout checks



32
33
34
 
# File 'lib/receptor_controller/client/configuration.rb', line 32

def response_timeout_poll_time
  @response_timeout_poll_time
end

Class Method Details

.default ⇒ Object 



55
56
57
 
# File 'lib/receptor_controller/client/configuration.rb', line 55

def self.default
  @@default ||= new
end

Instance Method Details

#configure {|_self| ... } ⇒ Object

Yields:

  • (_self)

Yield Parameters:



59
60
61
 
# File 'lib/receptor_controller/client/configuration.rb', line 59

def configure
  yield(self) if block_given?
end

#connection_status_url ⇒ Object 



77
78
79
 
# File 'lib/receptor_controller/client/configuration.rb', line 77

def connection_status_url
  File.join(controller_url, connection_status_path)
end

#controller_url ⇒ Object 



73
74
75
 
# File 'lib/receptor_controller/client/configuration.rb', line 73

def controller_url
  "#{controller_scheme}://#{controller_host}".sub(/\/+\z/, '')
end

#job_url ⇒ Object 



81
82
83
 
# File 'lib/receptor_controller/client/configuration.rb', line 81

def job_url
  File.join(controller_url, job_path)
end