Package com.lightbend.cinnamon.akka.stream

Class CinnamonAttributes.FlowWithInstrumented<In,​Out,​Mat>

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

    • Constructor Summary

      Constructors 
      Constructor Description
      FlowWithInstrumented​(akka.stream.Graph<akka.stream.FlowShape<In,​Out>,​Mat> flow)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      akka.stream.scaladsl.Flow<In,​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)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • FlowWithInstrumented

        public FlowWithInstrumented​(akka.stream.Graph<akka.stream.FlowShape<In,​Out>,​Mat> flow)

    • Method Detail

      • instrumentedPartial

        public akka.stream.scaladsl.Flow<In,​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)