c

cloudflow.akkastream

AkkaStreamletContextImpl

final class AkkaStreamletContextImpl extends AkkaStreamletContext

Implementation of the StreamletContext trait.

Linear Supertypes
AkkaStreamletContext, StreamletContext, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AkkaStreamletContextImpl
  2. AkkaStreamletContext
  3. StreamletContext
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new AkkaStreamletContextImpl(streamletDefinition: StreamletDefinition, sys: ActorSystem)

Type Members

  1. case class MountedPathUnavailableException(volumeMount: VolumeMount) extends Exception with Product with Serializable
    Definition Classes
    StreamletContext

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  6. def committableSink[T](committerSettings: CommitterSettings): Sink[(T, Committable), NotUsed]
    Definition Classes
    AkkaStreamletContextImpl → AkkaStreamletContext
  7. def committableSink[T](outlet: CodecOutlet[T], committerSettings: CommitterSettings): Sink[(T, Committable), NotUsed]
    Definition Classes
    AkkaStreamletContextImpl → AkkaStreamletContext
  8. def config: Config

    The full configuration for the Streamlet, containing all deployment-time configuration parameters on top of the normal configuration

    The full configuration for the Streamlet, containing all deployment-time configuration parameters on top of the normal configuration

    Definition Classes
    AkkaStreamletContextImpl → StreamletContext
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  11. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  12. def findTopicForPort(port: StreamletPort): Topic

    Get the savepoint path (topic name) from the port

    Get the savepoint path (topic name) from the port

    port

    the StreamletPort

    returns

    the savepoint path

    Definition Classes
    StreamletContext
    Exceptions thrown

    TopicForPortNotFoundException if there is no mapping found

  13. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. def getMountedPath(volumeMount: VolumeMount): Path

    The path mounted for a VolumeMount request from a streamlet.

    The path mounted for a VolumeMount request from a streamlet. In a clustered deployment, the mounted path will correspond to the requested mount path in the VolumeMount definition. In a local environment, this path will be replaced by a local folder.

    volumeMount

    the volumeMount declaration for which we want to obtain the mounted path.

    returns

    the path where the volume is mounted.

    Definition Classes
    StreamletContext
    Exceptions thrown

    MountedPathUnavailableException in the case the path is not available.

  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. def internalKafkaBootstrapServers: String

    The default bootstrapServers for the Kafka broker that has been installed or configured to be used globally for all Cloudflow applications

    The default bootstrapServers for the Kafka broker that has been installed or configured to be used globally for all Cloudflow applications

    Definition Classes
    StreamletContext
  17. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  18. val killSwitch: SharedKillSwitch
  19. def metricTags(): Map[String, String]
    Definition Classes
    AkkaStreamletContextImpl → AkkaStreamletContext
  20. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  21. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  22. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  23. def onStop(f: () ⇒ Future[Dun]): Unit

    Registers a callback, which is called when the streamlet is stopped.

    Registers a callback, which is called when the streamlet is stopped. It is usually used to close resources that have been created in the streamlet.

    Definition Classes
    AkkaStreamletContextImpl → AkkaStreamletContext
  24. def plainSink[T](outlet: CodecOutlet[T]): Sink[T, NotUsed]
    Definition Classes
    AkkaStreamletContextImpl → AkkaStreamletContext
  25. def plainSource[T](inlet: CodecInlet[T], resetPosition: ResetPosition = Latest): Source[T, NotUsed]
    Definition Classes
    AkkaStreamletContextImpl → AkkaStreamletContext
  26. def signalReady(): Boolean

    Signals that the streamlet is ready to process data.

    Signals that the streamlet is ready to process data.

    When a streamlet is run using AkkaStreamletTestkit.run, a StreamletExecution is returned. signalReady completes the ready future. ready can be used for instance to wait for a Server streamlet to signal that it is ready to accept requests.

    returns

    true if and only if successfully signalled. Otherwise false.

    Definition Classes
    AkkaStreamletContextImpl → AkkaStreamletContext
  27. def sinkRef[T](outlet: CodecOutlet[T]): WritableSinkRef[T]

    Creates a SinkRef to write to, for the specified CodecOutlet

    Creates a SinkRef to write to, for the specified CodecOutlet

    outlet

    the specified CodecOutlet

    returns

    the WritableSinkRef created

    Definition Classes
    AkkaStreamletContextImpl → AkkaStreamletContext
  28. def sourceWithCommittableContext[T](inlet: CodecInlet[T]): SourceWithCommittableContext[T]
    Definition Classes
    AkkaStreamletContextImpl → AkkaStreamletContext
  29. def stop(): Future[Dun]

    Stops the streamlet.

    Stops the streamlet.

    Definition Classes
    AkkaStreamletContextImpl → AkkaStreamletContext
  30. final def streamletConfig: Config

    The subset of configuration specific to a single named instance of a streamlet.

    The subset of configuration specific to a single named instance of a streamlet.

    A Streamlet can specify the set of environment- and instance-specific configuration keys it will use during runtime through configParameters. Those keys will then be made available through this configuration.

    An empty configuration will be returned if the streamlet doesn't contain any configuration parameters.

    Definition Classes
    StreamletContext
  31. val streamletExecution: StreamletExecution
    Definition Classes
    AkkaStreamletContextImpl → AkkaStreamletContext
  32. def streamletRef: String

    The streamlet reference which identifies the streamlet in the blueprint.

    The streamlet reference which identifies the streamlet in the blueprint. It is used in a Streamlet for logging and metrics, referring back to the streamlet instance using a name recognizable by the user.

    Definition Classes
    StreamletContext
  33. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  34. implicit val system: ActorSystem

    The system in which the AkkaStreamlet will be run.

    The system in which the AkkaStreamlet will be run.

    Definition Classes
    AkkaStreamletContextImpl → AkkaStreamletContext
  35. def toString(): String
    Definition Classes
    AnyRef → Any
  36. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  37. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  38. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Deprecated Value Members

  1. def sourceWithOffsetContext[T](inlet: CodecInlet[T]): SourceWithOffsetContext[T]
    Definition Classes
    AkkaStreamletContextImpl → AkkaStreamletContext
    Annotations
    @deprecated
    Deprecated

    (Since version 1.3.4) Use sourceWithCommittableContext

Inherited from AkkaStreamletContext

Inherited from StreamletContext

Inherited from AnyRef

Inherited from Any

Ungrouped