Class: Jubatus::Graph::Client::Graph

Inherits:
Common::ClientBase show all
Includes:
Common
Defined in:
lib/jubatus/graph/client.rb

Instance Method Summary collapse

Methods included from Common

check_type, check_types

Methods inherited from Common::ClientBase

connect, #do_mix, #get_client, #get_config, #get_name, #get_proxy_status, #get_status, #load, #save, #set_name

Constructor Details

#initialize(host, port, name, timeout_sec = 10) ⇒ Graph

Returns a new instance of Graph.


16
17
18
# File 'lib/jubatus/graph/client.rb', line 16

def initialize(host, port, name, timeout_sec=10)
  super
end

Instance Method Details

#add_centrality_query(query) ⇒ Object


53
54
55
56
# File 'lib/jubatus/graph/client.rb', line 53

def add_centrality_query(query)
  @jubatus_client.call("add_centrality_query", [query], TBool.new,
      [TUserDef.new(PresetQuery)])
end

#add_shortest_path_query(query) ⇒ Object


58
59
60
61
# File 'lib/jubatus/graph/client.rb', line 58

def add_shortest_path_query(query)
  @jubatus_client.call("add_shortest_path_query", [query], TBool.new,
      [TUserDef.new(PresetQuery)])
end

#clearObject


82
83
84
# File 'lib/jubatus/graph/client.rb', line 82

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

#create_edge(node_id, e) ⇒ Object


33
34
35
36
# File 'lib/jubatus/graph/client.rb', line 33

def create_edge(node_id, e)
  @jubatus_client.call("create_edge", [node_id, e], TInt.new(false, 8),
      [TString.new, TUserDef.new(Edge)])
end

#create_edge_here(edge_id, e) ⇒ Object


106
107
108
109
# File 'lib/jubatus/graph/client.rb', line 106

def create_edge_here(edge_id, e)
  @jubatus_client.call("create_edge_here", [edge_id, e], TBool.new, [TInt.new(
      false, 8), TUserDef.new(Edge)])
end

#create_nodeObject


20
21
22
# File 'lib/jubatus/graph/client.rb', line 20

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

#create_node_here(node_id) ⇒ Object


96
97
98
99
# File 'lib/jubatus/graph/client.rb', line 96

def create_node_here(node_id)
  @jubatus_client.call("create_node_here", [node_id], TBool.new,
      [TString.new])
end

#get_centrality(node_id, centrality_type, query) ⇒ Object


48
49
50
51
# File 'lib/jubatus/graph/client.rb', line 48

def get_centrality(node_id, centrality_type, query)
  @jubatus_client.call("get_centrality", [node_id, centrality_type, query],
      TFloat.new, [TString.new, TInt.new(true, 4), TUserDef.new(PresetQuery)])
end

#get_edge(node_id, edge_id) ⇒ Object


91
92
93
94
# File 'lib/jubatus/graph/client.rb', line 91

def get_edge(node_id, edge_id)
  @jubatus_client.call("get_edge", [node_id, edge_id], TUserDef.new(Edge),
      [TString.new, TInt.new(false, 8)])
end

#get_node(node_id) ⇒ Object


86
87
88
89
# File 'lib/jubatus/graph/client.rb', line 86

def get_node(node_id)
  @jubatus_client.call("get_node", [node_id], TUserDef.new(Node),
      [TString.new])
end

#get_shortest_path(query) ⇒ Object


73
74
75
76
# File 'lib/jubatus/graph/client.rb', line 73

def get_shortest_path(query)
  @jubatus_client.call("get_shortest_path", [query], TList.new(TString.new),
      [TUserDef.new(ShortestPathQuery)])
end

#remove_centrality_query(query) ⇒ Object


63
64
65
66
# File 'lib/jubatus/graph/client.rb', line 63

def remove_centrality_query(query)
  @jubatus_client.call("remove_centrality_query", [query], TBool.new,
      [TUserDef.new(PresetQuery)])
end

#remove_edge(node_id, edge_id) ⇒ Object


43
44
45
46
# File 'lib/jubatus/graph/client.rb', line 43

def remove_edge(node_id, edge_id)
  @jubatus_client.call("remove_edge", [node_id, edge_id], TBool.new,
      [TString.new, TInt.new(false, 8)])
end

#remove_global_node(node_id) ⇒ Object


101
102
103
104
# File 'lib/jubatus/graph/client.rb', line 101

def remove_global_node(node_id)
  @jubatus_client.call("remove_global_node", [node_id], TBool.new,
      [TString.new])
end

#remove_node(node_id) ⇒ Object


24
25
26
# File 'lib/jubatus/graph/client.rb', line 24

def remove_node(node_id)
  @jubatus_client.call("remove_node", [node_id], TBool.new, [TString.new])
end

#remove_shortest_path_query(query) ⇒ Object


68
69
70
71
# File 'lib/jubatus/graph/client.rb', line 68

def remove_shortest_path_query(query)
  @jubatus_client.call("remove_shortest_path_query", [query], TBool.new,
      [TUserDef.new(PresetQuery)])
end

#update_edge(node_id, edge_id, e) ⇒ Object


38
39
40
41
# File 'lib/jubatus/graph/client.rb', line 38

def update_edge(node_id, edge_id, e)
  @jubatus_client.call("update_edge", [node_id, edge_id, e], TBool.new,
      [TString.new, TInt.new(false, 8), TUserDef.new(Edge)])
end

#update_indexObject


78
79
80
# File 'lib/jubatus/graph/client.rb', line 78

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

#update_node(node_id, property) ⇒ Object


28
29
30
31
# File 'lib/jubatus/graph/client.rb', line 28

def update_node(node_id, property)
  @jubatus_client.call("update_node", [node_id, property], TBool.new,
      [TString.new, TMap.new(TString.new, TString.new)])
end