Class: LS4::DataServerURLService

Inherits:
Service show all
Defined in:
lib/ls4/service/data_server_url.rb

Instance Method Summary collapse

Methods inherited from Service

init

Methods included from EventBus::SingletonMixin

#ebus_bind!, #ebus_connect, extended

Methods included from EventBus::BusMixin

#ebus_all_slots, #ebus_disconnect!

Methods included from EventBus::DeclarerBase::Methods

#connect, #ebus_all_slots, #ebus_call_log, #ebus_call_slots, #ebus_signal_error, #ebus_signal_log, #ebus_signal_slots

Methods included from EventBus::DeclarerBase

#call_slot, #signal_slot

Constructor Details

#initialize ⇒ DataServerURLService

%p path encoded key %k url encoded key %v vtime %r rsid



26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/ls4/service/data_server_url.rb', line 26

def initialize
  host = ConfigBus.self_address.host
  if redirect_http_port = ConfigBus.http_redirect_port
    if redirect_http_path_format = ConfigBus.http_redirect_path_format
      @format = "http://#{host}:#{redirect_http_port}/#{redirect_http_path_format}"
      @format << '%p' unless @format.include?('%')
    else
      @format = "http://#{host}:#{redirect_http_port}/%p"
    end

  elsif self_http_address = ConfigBus.http_gateway_address
    @format = "http://#{host}:#{self_http_address.port}/direct/%r/%v/%k"

  else
    @format = nil
  end
end

Instance Method Details

#rpc_url_direct(okey) ⇒ Object 



44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/ls4/service/data_server_url.rb', line 44

def rpc_url_direct(okey)
  unless @format
    raise "redirect url is not configured"
  end

  unless StorageBus.exist(okey.vtime, okey.key)
    return nil
  end

  format_url(okey)
end