class Jubatus::Common::ClientBase
Public Class Methods
connect(host, port, name, timeout_sec, &block)
click to toggle source
# File lib/jubatus/common/client.rb, line 53 def self.connect(host, port, name, timeout_sec, &block) begin client = self.new(host, port, name, timeout_sec) block.call(client) ensure client.get_client.close end end
new(host, port, name, timeout_sec)
click to toggle source
# File lib/jubatus/common/client.rb, line 47 def initialize(host, port, name, timeout_sec) @cli = MessagePack::RPC::Client.new(host, port) @cli.timeout = timeout_sec @jubatus_client = Jubatus::Common::Client.new(@cli, name) end
Public Instance Methods
do_mix()
click to toggle source
# File lib/jubatus/common/client.rb, line 92 def do_mix @jubatus_client.call("do_mix", [], TBool.new, []) end
get_client()
click to toggle source
# File lib/jubatus/common/client.rb, line 62 def get_client @cli end
get_config()
click to toggle source
# File lib/jubatus/common/client.rb, line 74 def get_config @jubatus_client.call("get_config", [], TString.new, []) end
get_name()
click to toggle source
# File lib/jubatus/common/client.rb, line 66 def get_name @jubatus_client.name end
get_proxy_status()
click to toggle source
# File lib/jubatus/common/client.rb, line 96 def get_proxy_status @jubatus_client.call("get_proxy_status", [], TMap.new(TString.new, TMap.new( TString.new, TString.new)), []) end
get_status()
click to toggle source
# File lib/jubatus/common/client.rb, line 87 def get_status @jubatus_client.call("get_status", [], TMap.new(TString.new, TMap.new( TString.new, TString.new)), []) end
load(id)
click to toggle source
# File lib/jubatus/common/client.rb, line 83 def load(id) @jubatus_client.call("load", [id], TBool.new, [TString.new]) end
save(id)
click to toggle source
# File lib/jubatus/common/client.rb, line 78 def save(id) @jubatus_client.call("save", [id], TMap.new(TString.new, TString.new), [TString.new]) end
set_name(name)
click to toggle source
# File lib/jubatus/common/client.rb, line 70 def set_name(name) @jubatus_client.name = name end