com.lightbend.cinnamon.akka.stream

Class CinnamonAttributes.SourceWithInstrumented<Out,Mat>

java.lang.Object

com.lightbend.cinnamon.akka.stream.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 and Description
SourceWithInstrumented(akka.stream.Graph<akka.stream.SourceShape<Out>,Mat> source)

Method Summary

Modifier and Type	Method and 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)