MCPcopy Index your code
hub / github.com/OpenTSDB/opentsdb / mockUID

Method mockUID

test/core/BaseTsdbTest.java:295–383  ·  view source on GitHub ↗

Mocks out the UID calls to match keys and values @param type The type of UID to deal with @param key The String name of the UID @param uid The byte array UID to pair up with

(final UniqueIdType type, final String key,
      final byte[] uid)

Source from the content-addressed store, hash-verified

293 * The byte array UID to pair up with
294 */
295 protected void mockUID(final UniqueIdType type, final String key,
296 final byte[] uid) {
297 switch (type) {
298 case METRIC:
299 when(metrics.getId(key)).thenReturn(uid);
300 when(metrics.getIdAsync(key))
301 .thenAnswer(new Answer<Deferred<byte[]>>() {
302 @Override
303 public Deferred<byte[]> answer(InvocationOnMock invocation)
304 throws Throwable {
305 return Deferred.fromResult(uid);
306 }
307 });
308 when(metrics.getOrCreateId(key)).thenReturn(uid);
309 when(metrics.getOrCreateIdAsync(key))
310 .thenAnswer(new Answer<Deferred<byte[]>>() {
311 @Override
312 public Deferred<byte[]> answer(InvocationOnMock invocation)
313 throws Throwable {
314 return Deferred.fromResult(uid);
315 }
316 });
317 when(metrics.getName(uid)).thenReturn(key);
318 when(metrics.getNameAsync(uid)).thenAnswer(new Answer<Deferred<String>>() {
319 @Override
320 public Deferred<String> answer(InvocationOnMock invocation)
321 throws Throwable {
322 return Deferred.fromResult(key);
323 }
324 });
325 break;
326 case TAGK:
327 when(tag_names.getId(key)).thenReturn(uid);
328 when(tag_names.getIdAsync(key))
329 .thenAnswer(new Answer<Deferred<byte[]>>() {
330 @Override
331 public Deferred<byte[]> answer(InvocationOnMock invocation)
332 throws Throwable {
333 return Deferred.fromResult(uid);
334 }
335 });
336 when(tag_names.getOrCreateId(key)).thenReturn(uid);
337 when(tag_names.getOrCreateIdAsync(key))
338 .thenAnswer(new Answer<Deferred<byte[]>>() {
339 @Override
340 public Deferred<byte[]> answer(InvocationOnMock invocation)
341 throws Throwable {
342 return Deferred.fromResult(uid);
343 }
344 });
345 when(tag_names.getName(uid)).thenReturn(key);
346 when(tag_names.getNameAsync(uid)).thenAnswer(new Answer<Deferred<String>>() {
347 @Override
348 public Deferred<String> answer(InvocationOnMock invocation)
349 throws Throwable {
350 return Deferred.fromResult(key);
351 }
352 });

Callers 8

beforeMethod · 0.95
setupMetricMapsMethod · 0.95
setupTagkMapsMethod · 0.95
setupTagvMapsMethod · 0.95
setupGroupByTagValuesMethod · 0.95
beforeMethod · 0.80
beforeMethod · 0.80
beforeMethod · 0.80

Calls 6

getIdAsyncMethod · 0.80
getOrCreateIdAsyncMethod · 0.80
getNameAsyncMethod · 0.80
getIdMethod · 0.65
getOrCreateIdMethod · 0.65
getNameMethod · 0.65

Tested by

no test coverage detected