Packages

class WriterSettings[Message] extends AnyRef

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

Built with @see WriterSettingsBuilder

Source
PravegaSettings.scala
Linear Supertypes
AnyRef, Any
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]