Class ITDependencies<T extends StorageComponent>


  • @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.

    • Constructor Detail

      • ITDependencies

        public ITDependencies()
    • Method Detail

      • 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