ZIO Pravega
0.11.2+6-0241b274-SNAPSHOT
DocsAPI
Generated with
Copyright (c) 2022-2024, Olivier NOUGUIER
Copyright (c) 2022-2024, Olivier NOUGUIER
ZIO Pravega/zio/zio.pravega/zio.pravega.admin/PravegaReaderGroupManager

PravegaReaderGroupManager

zio.pravega.admin.PravegaReaderGroupManager
See thePravegaReaderGroupManager companion object
trait PravegaReaderGroupManager

PravegaReaderGroupManager is a wrapper around the ReaderGroupManager Java API. It provides a ZIO interface to the ReaderGroupManager API.

Attributes

Companion
object
Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Abstract methods

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

Create a reader group with the given name and stream names. Note: This method is idempotent assuming called with the same name and config. This method may block.

Create a reader group with the given name and stream names. Note: This method is idempotent assuming called with the same name and config. This method may block.

Will fail if the reader group already exists and the config is different.

Attributes

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

Drop a reader group with the given name. This method may block.

Drop a reader group with the given name. This method may block.

Attributes

def openReaderGroup(readerGroupName: String): RIO[Scope, ReaderGroup]

Open a reader group with the given name. This method may block.

Open a reader group with the given name. This method may block.

Attributes

def readerOffline(groupName: String): Task[Int]

Mark a reader as offline. This method may block.

Mark a reader as offline. This method may block.

This can be used to force a reader to be re-created. This is useful if a reader is stuck in a bad state.

Attributes

Generated with
Copyright (c) 2022-2024, Olivier NOUGUIER
Copyright (c) 2022-2024, Olivier NOUGUIER