Module: NATS::RPC

Defined in:
lib/nats/rpc.rb,
lib/nats/rpc/client.rb,
lib/nats/rpc/servant.rb,
lib/nats/rpc/version.rb

Defined Under Namespace

Classes: Client, Servant

Constant Summary collapse

VERSION = 
"0.0.6"

Class Method Summary collapse

Class Method Details

.cluster_opts ⇒ Object 



11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
 
# File 'lib/nats/rpc.rb', line 11

def self.cluster_opts
  servers = ENV['NATS_RPC_SERVER_URLS']&.split(",")
  max_reconnect_attempts = ENV['NATS_RPC_MAX_RECONNECT_ATTEMPTS']&.to_i
  reconnect_time_wait = ENV['NATS_RPC_RECONNECT_TIME_WAIT']&.to_i

  opts = {}
  opts[:servers] = servers if servers
  opts[:max_reconnect_attempts] = max_reconnect_attempts if max_reconnect_attempts
  opts[:reconnect_time_wait] = reconnect_time_wait if reconnect_time_wait
  if ENV['NATS_RPC_DONT_RANDOMIZE_SERVERS']
    opts[:dont_randomize_servers] = ENV['NATS_RPC_DONT_RANDOMIZE_SERVERS'] == "true"
  end
  if ENV['NATS_RPC_RECONNECT']
    opts[:reconnect] = ENV['NATS_RPC_RECONNECT'] == "true"
  end

  p opts
  opts
end