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

#getDataTimeToLiveObject



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

#getServiceNamesObject



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_getDataTimeToLiveObject

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_getDependenciesObject

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_getServiceNamesObject

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_getServiceNamesToTraceIdsObject

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_getSpanDurationsObject

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_getSpanNamesObject

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_getTopAnnotationsObject

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_getTopKeyValueAnnotationsObject

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_getTraceCombosByIdsObject

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_getTraceIdsObject

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_getTraceIdsByAnnotationObject

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_getTraceIdsByServiceNameObject

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_getTraceIdsBySpanNameObject

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_getTracesByIdsObject

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_getTraceSummariesByIdsObject

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_getTraceTimelinesByIdsObject

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_getTraceTimeToLiveObject

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_setTraceTimeToLiveObject



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_tracesExistObject

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_getDataTimeToLiveObject



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_getServiceNamesObject



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