ZIO Pravega
0.9.1+12-65ab92db-SNAPSHOT
DocsAPI
Generated with
Copyright (c) 2022-2024, Olivier NOUGUIER
Copyright (c) 2022-2024, Olivier NOUGUIER
ZIO Pravega/zio/zio.pravega

zio.pravega

package zio.pravega

Members list

Packages

package zio.pravega.admin
package zio.pravega.saga
package zio.pravega.stream
package zio.pravega.table

Type members

Classlikes

case object BuildInfo

This object was generated by sbt-buildinfo.

This object was generated by sbt-buildinfo.

Attributes

Supertypes
trait Singleton
trait Product
trait Mirror
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
Self type
BuildInfo.type
object PravegaClientConfig

Attributes

Supertypes
class Object
trait Matchable
class Any
Self type
trait PravegaStream

Pravega Stream API.

Pravega Stream API.

This API is a wrapper around the Pravega Java API.

Attributes

Companion
object
Supertypes
class Object
trait Matchable
class Any
object PravegaStream

Pravega Stream API.

Pravega Stream API.

This API is a wrapper around the Pravega Java API.

Attributes

Companion
trait
Supertypes
class Object
trait Matchable
class Any
Self type
trait PravegaTable

Pravega Table API.

Pravega Table API.

Attributes

Companion
object
Supertypes
class Object
trait Matchable
class Any
object PravegaTable

Pravega Table API companion object with accessible methods.

Pravega Table API companion object with accessible methods.

Attributes

Companion
trait
Supertypes
class Object
trait Matchable
class Any
Self type
trait PravegaTableManager

Pravega Admin API for KeyValueTable.

Pravega Admin API for KeyValueTable.

Attributes

Companion
object
Supertypes
class Object
trait Matchable
class Any
object PravegaTableManager

Pravega Admin API for KeyValueTable.

Pravega Admin API for KeyValueTable.

Attributes

Companion
trait
Supertypes
class Object
trait Matchable
class Any
Self type
class ReaderSettings[Message]

Reader settings that must be provided to @see zio.pravega.PravegaStream#stream

Reader settings that must be provided to @see zio.pravega.PravegaStream#stream

Built with @see ReaderSettingsBuilder

Attributes

Supertypes
class Object
trait Matchable
class Any
class ReaderSettingsBuilder(config: Config, readerConfigBuilder: ReaderConfigBuilder, readerConfigCustomizer: Option[ReaderConfigBuilder => ReaderConfigBuilder], timeout: Duration, readerId: Option[String])

Attributes

Companion
object
Supertypes
class Object
trait Matchable
class Any
object ReaderSettingsBuilder

Attributes

Companion
class
Supertypes
class Object
trait Matchable
class Any
Self type
final case class TableEntry[+V](tableKey: TableKey, version: Version, value: V)

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
class TableReaderSettings[K, V](keyValueTableClientConfiguration: KeyValueTableClientConfiguration, valueSerializer: Serializer[V], tableKey: K => TableKey, maximumInflightMessages: Int, val maxEntriesAtOnce: Int)

Attributes

Supertypes
class Object
trait Matchable
class Any
class TableReaderSettingsBuilder[K, V](config: Config, keySerializer: Serializer[K], valueSerializer: Serializer[V], tableKeyExtractor: Option[K => TableKey], configurationBuilder: KeyValueTableClientConfigurationBuilder, configurationCustomizer: Option[KeyValueTableClientConfigurationBuilder => KeyValueTableClientConfigurationBuilder], maximumInflightMessages: Int, maxEntriesAtOnce: Int)

Attributes

Companion
object
Supertypes
class Object
trait Matchable
class Any
object TableReaderSettingsBuilder

Attributes

Companion
class
Supertypes
class Object
trait Matchable
class Any
Self type
class TableWriterSettings[K, V](keyValueTableClientConfiguration: KeyValueTableClientConfiguration, valueSerializer: Serializer[V], tableKey: K => TableKey, maximumInflightMessages: Int)

Table Writer settings that must be provided to @see Sink zio.pravega.PravegaStream.sink Built with @see WriterSettingsBuilder

Table Writer settings that must be provided to @see Sink zio.pravega.PravegaStream.sink Built with @see WriterSettingsBuilder

Attributes

Supertypes
class Object
trait Matchable
class Any
class TableWriterSettingsBuilder[K, V](config: Config, keySerializer: Serializer[K], valueSerializer: Serializer[V], tableKeyExtractor: Option[K => TableKey], configurationBuilder: KeyValueTableClientConfigurationBuilder, configurationCustomizer: Option[KeyValueTableClientConfigurationBuilder => KeyValueTableClientConfigurationBuilder], maximumInflightMessages: Int)

Attributes

Companion
object
Supertypes
class Object
trait Matchable
class Any
object TableWriterSettingsBuilder

Attributes

Companion
class
Supertypes
class Object
trait Matchable
class Any
Self type
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

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

Built with @see WriterSettingsBuilder

Attributes

Supertypes
class Object
trait Matchable
class Any
class WriterSettingsBuilder[Message](config: Config, eventWriterConfigBuilder: EventWriterConfigBuilder, eventWriterConfigCustomizer: Option[EventWriterConfigBuilder => EventWriterConfigBuilder], maximumInflightMessages: Int, keyExtractor: Option[Message => String])

Attributes

Companion
object
Supertypes
class Object
trait Matchable
class Any
object WriterSettingsBuilder

Attributes

Companion
class
Supertypes
class Object
trait Matchable
class Any
Self type
Generated with
Copyright (c) 2022-2024, Olivier NOUGUIER
Copyright (c) 2022-2024, Olivier NOUGUIER