PravegaTableManager

zio.pravega.PravegaTableManager
See thePravegaTableManager companion trait

Pravega Admin API for KeyValueTable.

Attributes

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

Members list

Value members

Concrete methods

def createTable(scope: String, tableName: String, config: KeyValueTableConfiguration): RIO[PravegaTableManager & Scope, Boolean]

Create a KeyValueTable with the given name and config, may block.

Create a KeyValueTable with the given name and config, may block.

Will return false if the KeyValueTable already exists, hence true if it was effectively created.

Attributes

def deleteTable(scope: String, tableName: String): RIO[PravegaTableManager & Scope, Boolean]

Delete a KeyValueTable with the given name, may block.

Delete a KeyValueTable with the given name, may block.

Will return false if the KeyValueTable does not exist, hence true if it was effectively dropped.

Attributes

def listTables(scope: String): ZStream[PravegaTableManager, Throwable, KeyValueTableInfo]

List all the KeyValueTables in the Pravega cluster. This method may block.

List all the KeyValueTables in the Pravega cluster. This method may block.

Attributes

def live(clientConfig: ClientConfig): RLayer[Scope, PravegaTableManager]

ZLayer to provide a PravegaTableManager from a ClientConfig.

ZLayer to provide a PravegaTableManager from a ClientConfig.

Attributes

Concrete fields

val live: RLayer[Scope & ClientConfig, PravegaTableManager]

ZLayer to provide a PravegaTableManager from a environment with a ClientConfig.

ZLayer to provide a PravegaTableManager from a environment with a ClientConfig.

Attributes