PravegaReaderGroupManager

zio.pravega.admin.PravegaReaderGroupManager
See thePravegaReaderGroupManager companion trait

Attributes

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

Members list

Value members

Concrete methods

def createReaderGroup[A](readerGroupName: String, streamNames: String*): ZIO[PravegaReaderGroupManager, Throwable, Boolean]

Create a reader group with the given name and stream names.

Create a reader group with the given name and stream names.

Note: This method is idempotent assuming called with the same name and config, but it will fail if the reader group already exists and the config is different.

This method may block.

Attributes

def createReaderGroup(readerGroupName: String, builder: ReaderGroupConfigBuilder, streamNames: String*): RIO[PravegaReaderGroupManager, Boolean]

Create a reader group with the given name and stream names.

Create a reader group with the given name and stream names.

Note: This method is idempotent assuming called with the same name and config, but it will fail if the reader group already exists and the config is different.

This method may block.

Value parameters

builder

A ReaderGroupConfigBuilder to configure the reader group

Attributes

def dropReaderGroup(scope: String, readerGroupName: String): RIO[PravegaReaderGroupManager, Boolean]

Drop a reader group with the given name.

Drop a reader group with the given name.

Attributes

def live(scope: String): RLayer[Scope & ClientConfig, PravegaReaderGroupManager]
def live(scope: String, clientConfig: ClientConfig): RLayer[Scope, PravegaReaderGroupManager]
def openReaderGroup(readerGroupName: String): RIO[PravegaReaderGroupManager & Scope, ReaderGroup]

Open a reader group with the given name.

Open a reader group with the given name.

Attributes

def readerOffline(groupName: String): RIO[PravegaReaderGroupManager, Int]

Remove a reader group with the given name.

Remove a reader group with the given name.

If some reason a Reader exited without releasing resource, calling this method can help.

This method may block.

Attributes