Class: Zipkin::ZipkinQuery::Client

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

Instance Method Summary collapse

Instance Method Details

#getDataTimeToLive ⇒ Object 



222
223
224
225
 
# File 'lib/zipkin_query/zipkin_query.rb', line 222

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

#getDependencies(start_time, end_time) ⇒ Object 



238
239
240
241
 
# File 'lib/zipkin_query/zipkin_query.rb', line 238

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

#getServiceNames ⇒ Object 



159
160
161
162
 
# File 'lib/zipkin_query/zipkin_query.rb', line 159

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

#getServiceNamesToTraceIds(time_stamp, service_name, rpc_name) ⇒ Object 



301
302
303
304
 
# File 'lib/zipkin_query/zipkin_query.rb', line 301

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 



286
287
288
289
 
# File 'lib/zipkin_query/zipkin_query.rb', line 286

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

#getSpanNames(service_name) ⇒ Object 



175
176
177
178
 
# File 'lib/zipkin_query/zipkin_query.rb', line 175

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

#getTopAnnotations(service_name) ⇒ Object 



254
255
256
257
 
# File 'lib/zipkin_query/zipkin_query.rb', line 254

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

#getTopKeyValueAnnotations(service_name) ⇒ Object 



270
271
272
273
 
# File 'lib/zipkin_query/zipkin_query.rb', line 270

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

#getTraceCombosByIds(trace_ids, adjust) ⇒ Object 



143
144
145
146
 
# File 'lib/zipkin_query/zipkin_query.rb', line 143

def getTraceCombosByIds(trace_ids, adjust)
  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, start_ts) ⇒ Object 



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

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

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



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

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

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



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

def getTraceIdsBySpanName(service_name, span_name, end_ts, limit, order, start_ts = 0)
  send_getTraceIdsBySpanName(service_name, span_name, end_ts, limit, order, start_ts)
  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) ⇒ Object 



127
128
129
130
 
# File 'lib/zipkin_query/zipkin_query.rb', line 127

def getTraceSummariesByIds(trace_ids, adjust)
  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 



206
207
208
209
 
# File 'lib/zipkin_query/zipkin_query.rb', line 206

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

#recv_getDataTimeToLive ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


231
232
233
234
235
236
 
# File 'lib/zipkin_query/zipkin_query.rb', line 231

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) 


247
248
249
250
251
252
 
# File 'lib/zipkin_query/zipkin_query.rb', line 247

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) 


168
169
170
171
172
173
 
# File 'lib/zipkin_query/zipkin_query.rb', line 168

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) 


310
311
312
313
314
 
# File 'lib/zipkin_query/zipkin_query.rb', line 310

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) 


295
296
297
298
299
 
# File 'lib/zipkin_query/zipkin_query.rb', line 295

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) 


184
185
186
187
188
189
 
# File 'lib/zipkin_query/zipkin_query.rb', line 184

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) 


263
264
265
266
267
268
 
# File 'lib/zipkin_query/zipkin_query.rb', line 263

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) 


279
280
281
282
283
284
 
# File 'lib/zipkin_query/zipkin_query.rb', line 279

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) 


152
153
154
155
156
157
 
# File 'lib/zipkin_query/zipkin_query.rb', line 152

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) 


136
137
138
139
140
141
 
# File 'lib/zipkin_query/zipkin_query.rb', line 136

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) 


215
216
217
218
219
220
 
# File 'lib/zipkin_query/zipkin_query.rb', line 215

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 



200
201
202
203
204
 
# File 'lib/zipkin_query/zipkin_query.rb', line 200

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 



227
228
229
 
# File 'lib/zipkin_query/zipkin_query.rb', line 227

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

#send_getDependencies(start_time, end_time) ⇒ Object 



243
244
245
 
# File 'lib/zipkin_query/zipkin_query.rb', line 243

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

#send_getServiceNames ⇒ Object 



164
165
166
 
# File 'lib/zipkin_query/zipkin_query.rb', line 164

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

#send_getServiceNamesToTraceIds(time_stamp, service_name, rpc_name) ⇒ Object 



306
307
308
 
# File 'lib/zipkin_query/zipkin_query.rb', line 306

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 



291
292
293
 
# File 'lib/zipkin_query/zipkin_query.rb', line 291

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 



180
181
182
 
# File 'lib/zipkin_query/zipkin_query.rb', line 180

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

#send_getTopAnnotations(service_name) ⇒ Object 



259
260
261
 
# File 'lib/zipkin_query/zipkin_query.rb', line 259

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

#send_getTopKeyValueAnnotations(service_name) ⇒ Object 



275
276
277
 
# File 'lib/zipkin_query/zipkin_query.rb', line 275

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

#send_getTraceCombosByIds(trace_ids, adjust) ⇒ Object 



148
149
150
 
# File 'lib/zipkin_query/zipkin_query.rb', line 148

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, start_ts) ⇒ Object 



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

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

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



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

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

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



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

def send_getTraceIdsBySpanName(service_name, span_name, end_ts, limit, order, start_ts)
  send_message('getTraceIdsBySpanName', GetTraceIdsBySpanName_args, :service_name => service_name, :span_name => span_name, :end_ts => end_ts, :limit => limit, :order => order, :start_ts => start_ts)
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 



132
133
134
 
# File 'lib/zipkin_query/zipkin_query.rb', line 132

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 



211
212
213
 
# File 'lib/zipkin_query/zipkin_query.rb', line 211

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

#send_setTraceTimeToLive(trace_id, ttl_seconds) ⇒ Object 



196
197
198
 
# File 'lib/zipkin_query/zipkin_query.rb', line 196

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 



191
192
193
194
 
# File 'lib/zipkin_query/zipkin_query.rb', line 191

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