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 forSpanStore
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 aszipkin2.internal.DependencyLinkerTest
also 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 void
configureStorageForTest(StorageComponent.Builder storage)
Configures aStorageComponent.Builder
with parameters for the test being executed.protected void
processDependencies(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
accept, accept, blockWhileInFlight, clear, initializeStoragePerTest, names, newStorageBuilder, store, traces
-
-
-
-
Method Detail
-
configureStorageForTest
protected final void configureStorageForTest(StorageComponent.Builder storage)
Description copied from class:ITStorage
Configures aStorageComponent.Builder
with parameters for the test being executed.- Specified by:
configureStorageForTest
in 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
-
-