Class: Zipkin::ZipkinQuery::Client

Inherits:
Object
  • Object
show all
Includes:
Thrift::Client
Defined in:
lib/zipkin_query/zipkin_query.rb

Instance Method Summary collapse

Instance Method Details

#getDataTimeToLive ⇒ Object 



224
225
226
227
 
# File 'lib/zipkin_query/zipkin_query.rb', line 224

def getDataTimeToLive()
  send_getDataTimeToLive()
  return recv_getDataTimeToLive()
end

#getDependencies(start_time, end_time) ⇒ Object 



240
241
242
243
 
# File 'lib/zipkin_query/zipkin_query.rb', line 240

def getDependencies(start_time, end_time)
  send_getDependencies(start_time, end_time)
  return recv_getDependencies()
end

#getServiceNames ⇒ Object 



161
162
163
164
 
# File 'lib/zipkin_query/zipkin_query.rb', line 161

def getServiceNames()
  send_getServiceNames()
  return recv_getServiceNames()
end

#getServiceNamesToTraceIds(time_stamp, service_name, rpc_name) ⇒ Object 



303
304
305
306
 
# File 'lib/zipkin_query/zipkin_query.rb', line 303

def getServiceNamesToTraceIds(time_stamp, service_name, rpc_name)
  send_getServiceNamesToTraceIds(time_stamp, service_name, rpc_name)
  return recv_getServiceNamesToTraceIds()
end

#getSpanDurations(time_stamp, service_name, rpc_name) ⇒ Object 



288
289
290
291
 
# File 'lib/zipkin_query/zipkin_query.rb', line 288

def getSpanDurations(time_stamp, service_name, rpc_name)
  send_getSpanDurations(time_stamp, service_name, rpc_name)
  return recv_getSpanDurations()
end

#getSpanNames(service_name) ⇒ Object 



177
178
179
180
 
# File 'lib/zipkin_query/zipkin_query.rb', line 177

def getSpanNames(service_name)
  send_getSpanNames(service_name)
  return recv_getSpanNames()
end

#getTopAnnotations(service_name) ⇒ Object 



256
257
258
259
 
# File 'lib/zipkin_query/zipkin_query.rb', line 256

def getTopAnnotations(service_name)
  send_getTopAnnotations(service_name)
  return recv_getTopAnnotations()
end

#getTopKeyValueAnnotations(service_name) ⇒ Object 



272
273
274
275
 
# File 'lib/zipkin_query/zipkin_query.rb', line 272

def getTopKeyValueAnnotations(service_name)
  send_getTopKeyValueAnnotations(service_name)
  return recv_getTopKeyValueAnnotations()
end

#getTraceCombosByIds(trace_ids, adjust = [1]) ⇒ Object 



145
146
147
148
 
# File 'lib/zipkin_query/zipkin_query.rb', line 145

def getTraceCombosByIds(trace_ids, adjust=[1])
  send_getTraceCombosByIds(trace_ids, adjust)
  return recv_getTraceCombosByIds()
end

#getTraceIds(request) ⇒ Object 



15
16
17
18
 
# File 'lib/zipkin_query/zipkin_query.rb', line 15

def getTraceIds(request)
  send_getTraceIds(request)
  return recv_getTraceIds()
end

#getTraceIdsByAnnotation(service_name, annotation, value, end_ts, limit, order) ⇒ Object 



63
64
65
66
 
# File 'lib/zipkin_query/zipkin_query.rb', line 63

def getTraceIdsByAnnotation(service_name, annotation, value, end_ts, limit, order)
  send_getTraceIdsByAnnotation(service_name, annotation, value, end_ts, limit, order)
  return recv_getTraceIdsByAnnotation()
end

#getTraceIdsByServiceName(service_name, end_ts, limit, order) ⇒ Object 



47
48
49
50
 
# File 'lib/zipkin_query/zipkin_query.rb', line 47

def getTraceIdsByServiceName(service_name, end_ts, limit, order)
  send_getTraceIdsByServiceName(service_name, end_ts, limit, order)
  return recv_getTraceIdsByServiceName()
end

#getTraceIdsBySpanName(service_name, span_name, end_ts, limit, order) ⇒ Object 



31
32
33
34
 
# File 'lib/zipkin_query/zipkin_query.rb', line 31

def getTraceIdsBySpanName(service_name, span_name, end_ts, limit, order)
  send_getTraceIdsBySpanName(service_name, span_name, end_ts, limit, order)
  return recv_getTraceIdsBySpanName()
end

#getTracesByIds(trace_ids, adjust) ⇒ Object 



95
96
97
98
 
# File 'lib/zipkin_query/zipkin_query.rb', line 95

def getTracesByIds(trace_ids, adjust)
  send_getTracesByIds(trace_ids, adjust)
  return recv_getTracesByIds()
end

#getTraceSummariesByIds(trace_ids, adjust = [1]) ⇒ Object

set adjust = [1] more info to see zipkinQuery.thrift line 79



129
130
131
132
 
# File 'lib/zipkin_query/zipkin_query.rb', line 129

def getTraceSummariesByIds(trace_ids, adjust=[1])
  send_getTraceSummariesByIds(trace_ids, adjust)
  return recv_getTraceSummariesByIds()
end

#getTraceTimelinesByIds(trace_ids, adjust) ⇒ Object 



111
112
113
114
 
# File 'lib/zipkin_query/zipkin_query.rb', line 111

def getTraceTimelinesByIds(trace_ids, adjust)
  send_getTraceTimelinesByIds(trace_ids, adjust)
  return recv_getTraceTimelinesByIds()
end

#getTraceTimeToLive(trace_id) ⇒ Object 



208
209
210
211
 
# File 'lib/zipkin_query/zipkin_query.rb', line 208

def getTraceTimeToLive(trace_id)
  send_getTraceTimeToLive(trace_id)
  return recv_getTraceTimeToLive()
end

#recv_getDataTimeToLive ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


233
234
235
236
237
238
 
# File 'lib/zipkin_query/zipkin_query.rb', line 233

def recv_getDataTimeToLive()
  result = receive_message(GetDataTimeToLive_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getDataTimeToLive failed: unknown result')
end

#recv_getDependencies ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


249
250
251
252
253
254
 
# File 'lib/zipkin_query/zipkin_query.rb', line 249

def recv_getDependencies()
  result = receive_message(GetDependencies_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getDependencies failed: unknown result')
end

#recv_getServiceNames ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


170
171
172
173
174
175
 
# File 'lib/zipkin_query/zipkin_query.rb', line 170

def recv_getServiceNames()
  result = receive_message(GetServiceNames_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getServiceNames failed: unknown result')
end

#recv_getServiceNamesToTraceIds ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


312
313
314
315
316
 
# File 'lib/zipkin_query/zipkin_query.rb', line 312

def recv_getServiceNamesToTraceIds()
  result = receive_message(GetServiceNamesToTraceIds_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getServiceNamesToTraceIds failed: unknown result')
end

#recv_getSpanDurations ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


297
298
299
300
301
 
# File 'lib/zipkin_query/zipkin_query.rb', line 297

def recv_getSpanDurations()
  result = receive_message(GetSpanDurations_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getSpanDurations failed: unknown result')
end

#recv_getSpanNames ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


186
187
188
189
190
191
 
# File 'lib/zipkin_query/zipkin_query.rb', line 186

def recv_getSpanNames()
  result = receive_message(GetSpanNames_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getSpanNames failed: unknown result')
end

#recv_getTopAnnotations ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


265
266
267
268
269
270
 
# File 'lib/zipkin_query/zipkin_query.rb', line 265

def recv_getTopAnnotations()
  result = receive_message(GetTopAnnotations_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTopAnnotations failed: unknown result')
end

#recv_getTopKeyValueAnnotations ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


281
282
283
284
285
286
 
# File 'lib/zipkin_query/zipkin_query.rb', line 281

def recv_getTopKeyValueAnnotations()
  result = receive_message(GetTopKeyValueAnnotations_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTopKeyValueAnnotations failed: unknown result')
end

#recv_getTraceCombosByIds ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


154
155
156
157
158
159
 
# File 'lib/zipkin_query/zipkin_query.rb', line 154

def recv_getTraceCombosByIds()
  result = receive_message(GetTraceCombosByIds_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTraceCombosByIds failed: unknown result')
end

#recv_getTraceIds ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


24
25
26
27
28
29
 
# File 'lib/zipkin_query/zipkin_query.rb', line 24

def recv_getTraceIds()
  result = receive_message(GetTraceIds_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTraceIds failed: unknown result')
end

#recv_getTraceIdsByAnnotation ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


72
73
74
75
76
77
 
# File 'lib/zipkin_query/zipkin_query.rb', line 72

def recv_getTraceIdsByAnnotation()
  result = receive_message(GetTraceIdsByAnnotation_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTraceIdsByAnnotation failed: unknown result')
end

#recv_getTraceIdsByServiceName ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


56
57
58
59
60
61
 
# File 'lib/zipkin_query/zipkin_query.rb', line 56

def recv_getTraceIdsByServiceName()
  result = receive_message(GetTraceIdsByServiceName_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTraceIdsByServiceName failed: unknown result')
end

#recv_getTraceIdsBySpanName ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


40
41
42
43
44
45
 
# File 'lib/zipkin_query/zipkin_query.rb', line 40

def recv_getTraceIdsBySpanName()
  result = receive_message(GetTraceIdsBySpanName_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTraceIdsBySpanName failed: unknown result')
end

#recv_getTracesByIds ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


104
105
106
107
108
109
 
# File 'lib/zipkin_query/zipkin_query.rb', line 104

def recv_getTracesByIds()
  result = receive_message(GetTracesByIds_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTracesByIds failed: unknown result')
end

#recv_getTraceSummariesByIds ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


138
139
140
141
142
143
 
# File 'lib/zipkin_query/zipkin_query.rb', line 138

def recv_getTraceSummariesByIds()
  result = receive_message(GetTraceSummariesByIds_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTraceSummariesByIds failed: unknown result')
end

#recv_getTraceTimelinesByIds ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


120
121
122
123
124
125
 
# File 'lib/zipkin_query/zipkin_query.rb', line 120

def recv_getTraceTimelinesByIds()
  result = receive_message(GetTraceTimelinesByIds_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTraceTimelinesByIds failed: unknown result')
end

#recv_getTraceTimeToLive ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


217
218
219
220
221
222
 
# File 'lib/zipkin_query/zipkin_query.rb', line 217

def recv_getTraceTimeToLive()
  result = receive_message(GetTraceTimeToLive_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getTraceTimeToLive failed: unknown result')
end

#recv_setTraceTimeToLive ⇒ Object 



202
203
204
205
206
 
# File 'lib/zipkin_query/zipkin_query.rb', line 202

def recv_setTraceTimeToLive()
  result = receive_message(SetTraceTimeToLive_result)
  raise result.qe unless result.qe.nil?
  return
end

#recv_tracesExist ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


88
89
90
91
92
93
 
# File 'lib/zipkin_query/zipkin_query.rb', line 88

def recv_tracesExist()
  result = receive_message(TracesExist_result)
  return result.success unless result.success.nil?
  raise result.qe unless result.qe.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'tracesExist failed: unknown result')
end

#send_getDataTimeToLive ⇒ Object 



229
230
231
 
# File 'lib/zipkin_query/zipkin_query.rb', line 229

def send_getDataTimeToLive()
  send_message('getDataTimeToLive', GetDataTimeToLive_args)
end

#send_getDependencies(start_time, end_time) ⇒ Object 



245
246
247
 
# File 'lib/zipkin_query/zipkin_query.rb', line 245

def send_getDependencies(start_time, end_time)
  send_message('getDependencies', GetDependencies_args, :start_time => start_time, :end_time => end_time)
end

#send_getServiceNames ⇒ Object 



166
167
168
 
# File 'lib/zipkin_query/zipkin_query.rb', line 166

def send_getServiceNames()
  send_message('getServiceNames', GetServiceNames_args)
end

#send_getServiceNamesToTraceIds(time_stamp, service_name, rpc_name) ⇒ Object 



308
309
310
 
# File 'lib/zipkin_query/zipkin_query.rb', line 308

def send_getServiceNamesToTraceIds(time_stamp, service_name, rpc_name)
  send_message('getServiceNamesToTraceIds', GetServiceNamesToTraceIds_args, :time_stamp => time_stamp, :service_name => service_name, :rpc_name => rpc_name)
end

#send_getSpanDurations(time_stamp, service_name, rpc_name) ⇒ Object 



293
294
295
 
# File 'lib/zipkin_query/zipkin_query.rb', line 293

def send_getSpanDurations(time_stamp, service_name, rpc_name)
  send_message('getSpanDurations', GetSpanDurations_args, :time_stamp => time_stamp, :service_name => service_name, :rpc_name => rpc_name)
end

#send_getSpanNames(service_name) ⇒ Object 



182
183
184
 
# File 'lib/zipkin_query/zipkin_query.rb', line 182

def send_getSpanNames(service_name)
  send_message('getSpanNames', GetSpanNames_args, :service_name => service_name)
end

#send_getTopAnnotations(service_name) ⇒ Object 



261
262
263
 
# File 'lib/zipkin_query/zipkin_query.rb', line 261

def send_getTopAnnotations(service_name)
  send_message('getTopAnnotations', GetTopAnnotations_args, :service_name => service_name)
end

#send_getTopKeyValueAnnotations(service_name) ⇒ Object 



277
278
279
 
# File 'lib/zipkin_query/zipkin_query.rb', line 277

def send_getTopKeyValueAnnotations(service_name)
  send_message('getTopKeyValueAnnotations', GetTopKeyValueAnnotations_args, :service_name => service_name)
end

#send_getTraceCombosByIds(trace_ids, adjust) ⇒ Object 



150
151
152
 
# File 'lib/zipkin_query/zipkin_query.rb', line 150

def send_getTraceCombosByIds(trace_ids, adjust)
  send_message('getTraceCombosByIds', GetTraceCombosByIds_args, :trace_ids => trace_ids, :adjust => adjust)
end

#send_getTraceIds(request) ⇒ Object 



20
21
22
 
# File 'lib/zipkin_query/zipkin_query.rb', line 20

def send_getTraceIds(request)
  send_message('getTraceIds', GetTraceIds_args, :request => request)
end

#send_getTraceIdsByAnnotation(service_name, annotation, value, end_ts, limit, order) ⇒ Object 



68
69
70
 
# File 'lib/zipkin_query/zipkin_query.rb', line 68

def send_getTraceIdsByAnnotation(service_name, annotation, value, end_ts, limit, order)
  send_message('getTraceIdsByAnnotation', GetTraceIdsByAnnotation_args, :service_name => service_name, :annotation => annotation, :value => value, :end_ts => end_ts, :limit => limit, :order => order)
end

#send_getTraceIdsByServiceName(service_name, end_ts, limit, order) ⇒ Object 



52
53
54
 
# File 'lib/zipkin_query/zipkin_query.rb', line 52

def send_getTraceIdsByServiceName(service_name, end_ts, limit, order)
  send_message('getTraceIdsByServiceName', GetTraceIdsByServiceName_args, :service_name => service_name, :end_ts => end_ts, :limit => limit, :order => order)
end

#send_getTraceIdsBySpanName(service_name, span_name, end_ts, limit, order) ⇒ Object 



36
37
38
 
# File 'lib/zipkin_query/zipkin_query.rb', line 36

def send_getTraceIdsBySpanName(service_name, span_name, end_ts, limit, order)
  send_message('getTraceIdsBySpanName', GetTraceIdsBySpanName_args, :service_name => service_name, :span_name => span_name, :end_ts => end_ts, :limit => limit, :order => order)
end

#send_getTracesByIds(trace_ids, adjust) ⇒ Object 



100
101
102
 
# File 'lib/zipkin_query/zipkin_query.rb', line 100

def send_getTracesByIds(trace_ids, adjust)
  send_message('getTracesByIds', GetTracesByIds_args, :trace_ids => trace_ids, :adjust => adjust)
end

#send_getTraceSummariesByIds(trace_ids, adjust) ⇒ Object 



134
135
136
 
# File 'lib/zipkin_query/zipkin_query.rb', line 134

def send_getTraceSummariesByIds(trace_ids, adjust)
  send_message('getTraceSummariesByIds', GetTraceSummariesByIds_args, :trace_ids => trace_ids, :adjust => adjust)
end

#send_getTraceTimelinesByIds(trace_ids, adjust) ⇒ Object 



116
117
118
 
# File 'lib/zipkin_query/zipkin_query.rb', line 116

def send_getTraceTimelinesByIds(trace_ids, adjust)
  send_message('getTraceTimelinesByIds', GetTraceTimelinesByIds_args, :trace_ids => trace_ids, :adjust => adjust)
end

#send_getTraceTimeToLive(trace_id) ⇒ Object 



213
214
215
 
# File 'lib/zipkin_query/zipkin_query.rb', line 213

def send_getTraceTimeToLive(trace_id)
  send_message('getTraceTimeToLive', GetTraceTimeToLive_args, :trace_id => trace_id)
end

#send_setTraceTimeToLive(trace_id, ttl_seconds) ⇒ Object 



198
199
200
 
# File 'lib/zipkin_query/zipkin_query.rb', line 198

def send_setTraceTimeToLive(trace_id, ttl_seconds)
  send_message('setTraceTimeToLive', SetTraceTimeToLive_args, :trace_id => trace_id, :ttl_seconds => ttl_seconds)
end

#send_tracesExist(trace_ids) ⇒ Object 



84
85
86
 
# File 'lib/zipkin_query/zipkin_query.rb', line 84

def send_tracesExist(trace_ids)
  send_message('tracesExist', TracesExist_args, :trace_ids => trace_ids)
end

#setTraceTimeToLive(trace_id, ttl_seconds) ⇒ Object 



193
194
195
196
 
# File 'lib/zipkin_query/zipkin_query.rb', line 193

def setTraceTimeToLive(trace_id, ttl_seconds)
  send_setTraceTimeToLive(trace_id, ttl_seconds)
  recv_setTraceTimeToLive()
end

#tracesExist(trace_ids) ⇒ Object 



79
80
81
82
 
# File 'lib/zipkin_query/zipkin_query.rb', line 79

def tracesExist(trace_ids)
  send_tracesExist(trace_ids)
  return recv_tracesExist()
end