Class: Flare::Tools::Node

Inherits:
Stats show all
Defined in:
lib/flare/tools/node.rb

Overview

Description

Constant Summary

Constants included from Util::Result

Util::Result::ClientError, Util::Result::Deleted, Util::Result::End, Util::Result::Error, Util::Result::Exists, Util::Result::Found, Util::Result::None, Util::Result::NotFound, Util::Result::NotStored, Util::Result::Ok, Util::Result::ServerError, Util::Result::Stored

Constants included from Util::Constant

Util::Constant::DefalutBwlimit, Util::Constant::DefaultIndexServerName, Util::Constant::DefaultIndexServerPort, Util::Constant::DefaultNodePort, Util::Constant::DefaultTimeout, Util::Constant::STATUS_NG, Util::Constant::STATUS_OK

Instance Method Summary collapse

Methods inherited from Stats

#stats_threads, #stats_threads_by_peer

Methods inherited from Client

#close, defcmd, defcmd_generic, defcmd_key, defcmd_listelement, defcmd_noreply, defcmd_oneline, defcmd_value, #host, #hostname, #initialize, open, #port, #received_size, #request, #required_version?, #sent_size, #server_version, #version

Methods included from Util::Logging

#debug, #error, #fatal, #info, logger, #puts, set_logger, #trace, #warn

Methods included from Util::Result

result_of_string, string_of_result

Constructor Details

This class inherits a constructor from Flare::Tools::Client

Instance Method Details

#cas(k, v, casunique, flag = 0, expire = 0) ⇒ Object 



46
47
48
49
50
 
# File 'lib/flare/tools/node.rb', line 46

def cas(k, v, casunique, flag = 0, expire = 0)
  r = cas_(k.chomp, flag, expire, v.size, casunique, v)
  r = true if r == ""
  r
end

#decr(k, v) ⇒ Object 



153
154
155
 
# File 'lib/flare/tools/node.rb', line 153

def decr(k, v)
  decr_(k.chomp, v.to_s)
end

#decr_noreply(k, v) ⇒ Object 



148
149
150
 
# File 'lib/flare/tools/node.rb', line 148

def decr_noreply(k, v)
  decr_noreply_(k.chomp, v.to_s)
end

#delete(k) ⇒ Object 



53
54
55
 
# File 'lib/flare/tools/node.rb', line 53

def delete(k)
  delete_(k.chomp)
end

#delete_noreply(k) ⇒ Object 



58
59
60
 
# File 'lib/flare/tools/node.rb', line 58

def delete_noreply(k)
  delete_noreply_(k.chomp)
end

#dump(wait = 0, part = 0, partsize = 1, bwlimit = 0, &block) ⇒ Object 



114
115
116
 
# File 'lib/flare/tools/node.rb', line 114

def dump(wait = 0, part = 0, partsize = 1, bwlimit = 0, &block)
  dump_(wait, part, partsize, bwlimit.to_i, &block)
end

#dumpkey(part = nil, partsize = nil, &block) ⇒ Object 



121
122
123
124
125
 
# File 'lib/flare/tools/node.rb', line 121

def dumpkey(part = nil, partsize = nil, &block)
  return dumpkey_0_(&block) if part.nil?
  return dumpkey_1_(part, &block) if partsize.nil?
  return dumpkey_2_(part, partsize, &block)
end

#flush_all ⇒ Object 



21
22
23
 
# File 'lib/flare/tools/node.rb', line 21

def flush_all
  flush_all_
end

#get(*keys, &block) ⇒ Object 



88
89
90
91
92
93
94
95
96
 
# File 'lib/flare/tools/node.rb', line 88

def get(*keys, &block)
  return false if keys.size == 0
  r = get_(keys.map{|x|x.chomp}.join(' '), &block)
  if r && keys.size == 1
    return false if r.size == 0
    return r[0] if r.size == 1
  end
  r
end

#gets(*keys, &block) ⇒ Object 



101
102
103
104
105
106
107
108
109
 
# File 'lib/flare/tools/node.rb', line 101

def gets(*keys, &block)
  return false if keys.size == 0
  r = gets_(keys.map{|x|x.chomp}.join(' '), &block)
  if r && keys.size == 1
    return false if r.size == 0
    return r[0] if r.size == 1
  end
  r
end

#incr(k, v) ⇒ Object 



141
142
143
 
# File 'lib/flare/tools/node.rb', line 141

def incr(k, v)
  incr_(k.chomp, v.to_s)
end

#incr_noreply(k, v) ⇒ Object 



136
137
138
 
# File 'lib/flare/tools/node.rb', line 136

def incr_noreply(k, v)
  incr_noreply_(k.chomp, v.to_s)
end

#set(k, v, flag = 0, expire = 0) ⇒ Object 



36
37
38
 
# File 'lib/flare/tools/node.rb', line 36

def set(k, v, flag = 0, expire = 0)
  set_(k.chomp, flag, expire, v.size, v)
end

#set_noreply(k, v, flag = 0, expire = 0) ⇒ Object 



41
42
43
 
# File 'lib/flare/tools/node.rb', line 41

def set_noreply(k, v, flag = 0, expire = 0)
  set_noreply_(k.chomp, flag, expire, v.size, v)
end

#set_state(host, port, state) ⇒ Object 



16
17
18
 
# File 'lib/flare/tools/node.rb', line 16

def set_state(host, port, state)
  set_state_(host, port, state)
end

#x_list_get(k, b, e, &block) ⇒ Object 



81
82
83
 
# File 'lib/flare/tools/node.rb', line 81

def x_list_get(k, b, e, &block)
  x_list_get_(k.chomp, b, e, &block)
end

#x_list_pop(k) ⇒ Object 



63
64
65
66
67
68
69
 
# File 'lib/flare/tools/node.rb', line 63

def x_list_pop(k)
  r = nil
  x_list_pop_(k.chomp) do |data, key, flag, len, version, expire|
    r = data
  end
  r
end

#x_list_push(k, v, flag = 0, expire = 0) ⇒ Object 



26
27
28
 
# File 'lib/flare/tools/node.rb', line 26

def x_list_push(k, v, flag = 0, expire = 0)
  x_list_push_(k.chomp, flag, expire, v.size, v)
end

#x_list_shift(k) ⇒ Object 



72
73
74
75
76
77
78
 
# File 'lib/flare/tools/node.rb', line 72

def x_list_shift(k)
  r = nil
  x_list_shift_(k.chomp) do |data, key, flag, len, version, expire|
    r = data
  end
  r
end

#x_list_unshift(k, v, flag = 0, expire = 0) ⇒ Object 



31
32
33
 
# File 'lib/flare/tools/node.rb', line 31

def x_list_unshift(k, v, flag = 0, expire = 0)
  x_list_unshift_(k.chomp, flag, expire, v.size, v)
end