io.pravega.client.admin

Interface ReaderGroupManager

All Superinterfaces:

AutoCloseable

public interface ReaderGroupManager
extends AutoCloseable

Used to create and manage reader groups.

Method Summary

Modifier and Type	Method and Description
void	close() Close this manager class.
ReaderGroup	createReaderGroup(String groupName, ReaderGroupConfig config, Set<String> streamNames) Creates a new ReaderGroup Readers will be able to join the group by calling ClientFactory.createReader(String, String, Serializer, ReaderConfig) .
void	deleteReaderGroup(String groupName) Deletes a reader group, removing any state associated with it.
ReaderGroup	getReaderGroup(String groupName) Returns the requested reader group.
static ReaderGroupManager	withScope(String scope, URI controllerUri) Creates a new instance of StreamManager.

Method Detail

withScope

static ReaderGroupManager withScope(String scope,
                                    URI controllerUri)

Creates a new instance of StreamManager.

Parameters:

scope - The Scope string.

controllerUri - The Controller URI.

Returns:

Instance of Stream Manager implementation.

createReaderGroup

ReaderGroup createReaderGroup(String groupName,
                              ReaderGroupConfig config,
                              Set<String> streamNames)

Creates a new ReaderGroup Readers will be able to join the group by calling ClientFactory.createReader(String, String, Serializer, ReaderConfig) . Once this is done they will start receiving events from the point defined in the config passed here.

Note: This method is idempotent assuming called with the same name and config. This method may block.

Parameters:

groupName - The name of the group to be created.

config - The configuration for the new ReaderGroup.

streamNames - The name of the streams the reader will read from.

Returns:

Newly created ReaderGroup object

deleteReaderGroup

void deleteReaderGroup(String groupName)

Deletes a reader group, removing any state associated with it. There should be no reader left on the group when this is called. If there are any, the group will be deleted from underneath them and they will encounter exceptions.

Parameters:

groupName - The group to be deleted.

getReaderGroup

ReaderGroup getReaderGroup(String groupName)

Returns the requested reader group.

Parameters:

groupName - The name of the group

Returns:

Reader group with the given name

close

void close()

Close this manager class. This will close any connections created through it.

Specified by:

close in interface AutoCloseable

See Also:

AutoCloseable.close()