package pravega
- Alphabetic
- Public
- Protected
Type Members
- class PravegaEvent[+Message] extends AnyRef
- final class PravegaReaderGroupManager extends AutoCloseable
- class ReaderSettings[Message] extends AnyRef
Reader settings that must be provided to @see pekko.stream.connectors.pravega.scaladsl.Pravega#source
Reader settings that must be provided to @see pekko.stream.connectors.pravega.scaladsl.Pravega#source
Built with @see ReaderSettingsBuilder
- class ReaderSettingsBuilder extends WithClientConfig
- class TableEntry[+V] extends AnyRef
- class TableReaderSettings[K, V] extends TableSettings[K, V]
- class TableReaderSettingsBuilder[K, V] extends WithClientConfig
- abstract class TableSettings[K, V] extends AnyRef
- Attributes
- protected
- class TableWriterSettings[K, V] extends TableSettings[K, V]
Table Writer settings that must be provided to @see Sink pekko.stream.connectors.pravega.scaladsl.PravegaTable.sink or @see Flow pekko.stream.connectors.pravega.scaladsl.PravegaTable.writeFlow
Table Writer settings that must be provided to @see Sink pekko.stream.connectors.pravega.scaladsl.PravegaTable.sink or @see Flow pekko.stream.connectors.pravega.scaladsl.PravegaTable.writeFlow
Built with @see WriterSettingsBuilder
- class TableWriterSettingsBuilder[K, V] extends WithClientConfig
- 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
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
- class WriterSettingsBuilder[Message] extends WithClientConfig
Value Members
- object ReaderSettingsBuilder
- object TableReaderSettingsBuilder
- object TableWriterSettingsBuilder
- object WriterSettingsBuilder