WriterSettings

zio.pravega.WriterSettings
class WriterSettings[Message](val eventWriterConfig: EventWriterConfig, val serializer: Serializer[Message], val keyExtractor: Option[Message => String], val maximumInflightMessages: Int)

Writer settings that must be provided to @see Sink zio.pravega.PravegaStream#sink

Built with @see WriterSettingsBuilder

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Concrete fields

val eventWriterConfig: EventWriterConfig
val keyExtractor: Option[Message => String]
val serializer: Serializer[Message]