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 forSpanStoreimplementations 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 aszipkin2.internal.DependencyLinkerTestalso defines many of these tests. The redundancy helps ensure integrated storage doesn't fail due to mismapping of data, for example.
-
-
Constructor Summary
Constructors Constructor Description ITDependencies()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected java.util.Map<java.lang.Long,java.util.List<DependencyLink>>aggregateLinks(java.util.List<Span> spans)Returns links aggregated by midnightprotected voidconfigureStorageForTest(StorageComponent.Builder storage)Configures aStorageComponent.Builderwith parameters for the test being executed.protected voidprocessDependencies(java.util.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
clear, initializeStoragePerTest, names, newStorageBuilder, store
-
-
-
-
Method Detail
-
configureStorageForTest
protected final void configureStorageForTest(StorageComponent.Builder storage)
Description copied from class:ITStorageConfigures aStorageComponent.Builderwith parameters for the test being executed.- Specified by:
configureStorageForTestin classITStorage<T extends StorageComponent>
-
processDependencies
protected void processDependencies(java.util.List<Span> spans) throws java.lang.Exception
Override if dependency processing is a separate job: it should complete before returning from this method.- Throws:
java.lang.Exception
-
aggregateLinks
protected java.util.Map<java.lang.Long,java.util.List<DependencyLink>> aggregateLinks(java.util.List<Span> spans)
Returns links aggregated by midnight
-
-