Package com.lightbend.cinnamon.akka.stream

Class CinnamonAttributes.SourceWithInstrumented<Out,​Mat>

  • Enclosing class:
    CinnamonAttributes
    public static class CinnamonAttributes.SourceWithInstrumented<Out,​Mat>
extends java.lang.Object
    Implicit convenience extension for adding Instrumented attributes to sources.

    • Constructor Summary

      Constructors 
      Constructor Description
      SourceWithInstrumented​(akka.stream.Graph<akka.stream.SourceShape<Out>,​Mat> source)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      akka.stream.scaladsl.Source<Out,​Mat> instrumentedPartial​(boolean reportByName, boolean reportByInstance, java.lang.String name, scala.collection.immutable.Map<java.lang.String,​java.lang.String> tags, boolean perOperator, boolean perConnection, boolean perBoundary, boolean perFlow, boolean substreams, boolean traceable)  
      <Mat2> Mat2 instrumentedRunWith​(akka.stream.Graph<akka.stream.SinkShape<Out>,​Mat2> sink, boolean reportByName, boolean reportByInstance, java.lang.String name, scala.collection.immutable.Map<java.lang.String,​java.lang.String> tags, boolean perOperator, boolean perConnection, boolean perBoundary, boolean perFlow, boolean substreams, boolean traceable, akka.stream.Materializer materializer)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • SourceWithInstrumented

        public SourceWithInstrumented​(akka.stream.Graph<akka.stream.SourceShape<Out>,​Mat> source)

    • Method Detail

      • instrumentedPartial

        public akka.stream.scaladsl.Source<Out,​Mat> instrumentedPartial​(boolean reportByName,
                                                                      boolean reportByInstance,
                                                                      java.lang.String name,
                                                                      scala.collection.immutable.Map<java.lang.String,​java.lang.String> tags,
                                                                      boolean perOperator,
                                                                      boolean perConnection,
                                                                      boolean perBoundary,
                                                                      boolean perFlow,
                                                                      boolean substreams,
                                                                      boolean traceable)

      • instrumentedRunWith

        public <Mat2> Mat2 instrumentedRunWith​(akka.stream.Graph<akka.stream.SinkShape<Out>,​Mat2> sink,
                                       boolean reportByName,
                                       boolean reportByInstance,
                                       java.lang.String name,
                                       scala.collection.immutable.Map<java.lang.String,​java.lang.String> tags,
                                       boolean perOperator,
                                       boolean perConnection,
                                       boolean perBoundary,
                                       boolean perFlow,
                                       boolean substreams,
                                       boolean traceable,
                                       akka.stream.Materializer materializer)