Packages

c

akka.stream.alpakka.pravega

WriterSettings

class WriterSettings[Message] extends AnyRef

Writer settings that must be provided to @see Sink akka.stream.alpakka.pravega.scaladsl.Pravega#sink or @see Flow akka.stream.alpakka.pravega.scaladsl.Pravega#flow

Built with @see WriterSettingsBuilder

Source
PravegaSettings.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. WriterSettings
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new WriterSettings(clientConfig: ClientConfig, eventWriterConfig: EventWriterConfig, serializer: Serializer[Message], keyExtractor: Option[(Message) => String], maximumInflightMessages: Int)

Value Members

  1. val clientConfig: ClientConfig
  2. val eventWriterConfig: EventWriterConfig
  3. val keyExtractor: Option[(Message) => String]
  4. val maximumInflightMessages: Int
  5. val serializer: Serializer[Message]