Class: Jp::JobPoolInstrumented::Client

Inherits:
Jp::JobPool::Client show all
Includes:
Thrift::Client
Defined in:
lib/rb/jp/gen-rb/job_pool_instrumented.rb

Instance Method Summary collapse

Methods inherited from Jp::JobPool::Client

#acquire, #add, #purge, #recv_acquire, #recv_add, #recv_purge, #send_acquire, #send_add, #send_purge

Methods inherited from FacebookService::Client

#aliveSince, #getCounter, #getCounters, #getCpuProfile, #getName, #getOption, #getOptions, #getStatus, #getStatusDetails, #getVersion, #recv_aliveSince, #recv_getCounter, #recv_getCounters, #recv_getCpuProfile, #recv_getName, #recv_getOption, #recv_getOptions, #recv_getStatus, #recv_getStatusDetails, #recv_getVersion, #recv_setOption, #reinitialize, #send_aliveSince, #send_getCounter, #send_getCounters, #send_getCpuProfile, #send_getName, #send_getOption, #send_getOptions, #send_getStatus, #send_getStatusDetails, #send_getVersion, #send_reinitialize, #send_setOption, #send_shutdown, #setOption, #shutdown

Instance Method Details

#acquire_count(pool_name) ⇒ Object 



62
63
64
65
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 62

def acquire_count(pool_name)
  send_acquire_count(pool_name)
  return recv_acquire_count()
end

#add_count(pool_name) ⇒ Object 



46
47
48
49
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 46

def add_count(pool_name)
  send_add_count(pool_name)
  return recv_add_count()
end

#empty_count(pool_name) ⇒ Object 



78
79
80
81
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 78

def empty_count(pool_name)
  send_empty_count(pool_name)
  return recv_empty_count()
end

#pools ⇒ Object 



16
17
18
19
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 16

def pools()
  send_pools()
  return recv_pools()
end

#purge_count(pool_name) ⇒ Object 



94
95
96
97
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 94

def purge_count(pool_name)
  send_purge_count(pool_name)
  return recv_purge_count()
end

#recv_acquire_count ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


71
72
73
74
75
76
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 71

def recv_acquire_count()
  result = receive_message(Acquire_count_result)
  return result.success unless result.success.nil?
  raise result.nsp unless result.nsp.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'acquire_count failed: unknown result')
end

#recv_add_count ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


55
56
57
58
59
60
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 55

def recv_add_count()
  result = receive_message(Add_count_result)
  return result.success unless result.success.nil?
  raise result.nsp unless result.nsp.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'add_count failed: unknown result')
end

#recv_empty_count ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


87
88
89
90
91
92
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 87

def recv_empty_count()
  result = receive_message(Empty_count_result)
  return result.success unless result.success.nil?
  raise result.nsp unless result.nsp.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'empty_count failed: unknown result')
end

#recv_pools ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


25
26
27
28
29
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 25

def recv_pools()
  result = receive_message(Pools_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'pools failed: unknown result')
end

#recv_purge_count ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


103
104
105
106
107
108
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 103

def recv_purge_count()
  result = receive_message(Purge_count_result)
  return result.success unless result.success.nil?
  raise result.nsp unless result.nsp.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'purge_count failed: unknown result')
end

#recv_start_time ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


40
41
42
43
44
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 40

def recv_start_time()
  result = receive_message(Start_time_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'start_time failed: unknown result')
end

#send_acquire_count(pool_name) ⇒ Object 



67
68
69
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 67

def send_acquire_count(pool_name)
  send_message('acquire_count', Acquire_count_args, :pool_name => pool_name)
end

#send_add_count(pool_name) ⇒ Object 



51
52
53
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 51

def send_add_count(pool_name)
  send_message('add_count', Add_count_args, :pool_name => pool_name)
end

#send_empty_count(pool_name) ⇒ Object 



83
84
85
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 83

def send_empty_count(pool_name)
  send_message('empty_count', Empty_count_args, :pool_name => pool_name)
end

#send_pools ⇒ Object 



21
22
23
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 21

def send_pools()
  send_message('pools', Pools_args)
end

#send_purge_count(pool_name) ⇒ Object 



99
100
101
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 99

def send_purge_count(pool_name)
  send_message('purge_count', Purge_count_args, :pool_name => pool_name)
end

#send_start_time ⇒ Object 



36
37
38
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 36

def send_start_time()
  send_message('start_time', Start_time_args)
end

#start_time ⇒ Object 



31
32
33
34
 
# File 'lib/rb/jp/gen-rb/job_pool_instrumented.rb', line 31

def start_time()
  send_start_time()
  return recv_start_time()
end