Class: Jubatus::Common::ClientBase

Inherits:

Object

• Object
• Jubatus::Common::ClientBase

Defined in:

lib/jubatus/common/client.rb

Direct Known Subclasses

Anomaly::Client::Anomaly, Bandit::Client::Bandit, Burst::Client::Burst, Jubatus::Classifier::Client::Classifier, Jubatus::Clustering::Client::Clustering, Graph::Client::Graph, NearestNeighbor::Client::NearestNeighbor, Recommender::Client::Recommender, Regression::Client::Regression, Stat::Client::Stat, Weight::Client::Weight

Class Method Summary

• .connect(host, port, name, timeout_sec, &block) ⇒ Object

Instance Method Summary

• #do_mix ⇒ Object
• #get_client ⇒ Object
• #get_config ⇒ Object
• #get_name ⇒ Object
• #get_proxy_status ⇒ Object
• #get_status ⇒ Object
• #initialize(host, port, name, timeout_sec) ⇒ ClientBase constructor

  A new instance of ClientBase.

• #load(id) ⇒ Object
• #save(id) ⇒ Object
• #set_name(name) ⇒ Object

Constructor Details

#initialize(host, port, name, timeout_sec) ⇒ ClientBase

Returns a new instance of ClientBase.

# 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

Class Method Details

.connect(host, port, name, timeout_sec, &block) ⇒ Object

# 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

Instance Method Details

#do_mix ⇒ Object

# File 'lib/jubatus/common/client.rb', line 92

def do_mix
  @jubatus_client.call("do_mix", [], TBool.new, [])
end

#get_client ⇒ Object

# File 'lib/jubatus/common/client.rb', line 62

def get_client
  @cli
end

#get_config ⇒ Object

# File 'lib/jubatus/common/client.rb', line 74

def get_config
  @jubatus_client.call("get_config", [], TString.new, [])
end

#get_name ⇒ Object

# File 'lib/jubatus/common/client.rb', line 66

def get_name
  @jubatus_client.name
end

#get_proxy_status ⇒ Object

# 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 ⇒ Object

# 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) ⇒ Object

# File 'lib/jubatus/common/client.rb', line 83

def load(id)
  @jubatus_client.call("load", [id], TBool.new, [TString.new])
end

#save(id) ⇒ Object

# 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) ⇒ Object

# File 'lib/jubatus/common/client.rb', line 70

def set_name(name)
  @jubatus_client.name = name
end