PravegaTableManager

zio.pravega.PravegaTableManager
See thePravegaTableManager companion object

Pravega Admin API for KeyValueTable.

Attributes

Companion
object
Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Abstract methods

def createTable(scope: String, tableName: String, config: KeyValueTableConfiguration): RIO[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[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[Any, 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