Package zipkin2.storage

Class ITDependencies<T extends StorageComponent>

java.lang.Object

zipkin2.storage.ITStorage<T>

zipkin2.storage.ITDependencies<T>

@TestInstance(PER_CLASS)
public abstract class ITDependencies<T extends StorageComponent>
extends ITStorage<T>

Base test for SpanStore implementations that support dependency aggregation. Subtypes should create a connection to a real backend, even if that backend is in-process.

This is a replacement for zipkin.storage.DependenciesTest. There is some redundancy as zipkin2.internal.DependencyLinkerTest also defines many of these tests. The redundancy helps ensure integrated storage doesn't fail due to mismapping of data, for example.

Field Summary

Fields inherited from class zipkin2.storage.ITStorage

storage

Constructor Summary

Constructors

Constructor	Description
ITDependencies()

Method Summary

Modifier and Type	Method	Description
protected Map<Long,List<DependencyLink>>	aggregateLinks(List<Span> spans)	Returns links aggregated by midnight
protected void	configureStorageForTest(StorageComponent.Builder storage)	Configures a StorageComponent.Builder with parameters for the test being executed.
protected void	processDependencies(List<Span> spans)	Override if dependency processing is a separate job: it should complete before returning from this method.

Methods inherited from class zipkin2.storage.ITStorage

accept, accept, blockWhileInFlight, clear, initializeStoragePerTest, names, newStorageBuilder, store, traces

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ITDependencies

public ITDependencies()

Method Details

configureStorageForTest

protected final void configureStorageForTest(StorageComponent.Builder storage)

Description copied from class: ITStorage

Configures a StorageComponent.Builder with parameters for the test being executed.

Specified by:

configureStorageForTest in class ITStorage<T extends StorageComponent>

processDependencies

protected void processDependencies(List<Span> spans) throws Exception

Override if dependency processing is a separate job: it should complete before returning from this method.

Throws:

Exception

aggregateLinks

protected Map<Long,List<DependencyLink>> aggregateLinks(List<Span> spans)

Returns links aggregated by midnight