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 trait
object PravegaReaderGroupManager

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]
def createReaderGroup(readerGroupName: String, builder: ReaderGroupConfigBuilder, streamNames: String*): RIO[PravegaReaderGroupManager, Boolean]
def dropReaderGroup(scope: String, readerGroupName: String): RIO[PravegaReaderGroupManager, Boolean]
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]
def readerOffline(groupName: String): RIO[PravegaReaderGroupManager, Int]
Generated with
Copyright (c) 2022-2024, Olivier NOUGUIER
Copyright (c) 2022-2024, Olivier NOUGUIER