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