Package org.restheart.mongodb.handlers.changestreams

Class ChangeStreamsRegistry

java.lang.Object

org.restheart.mongodb.handlers.changestreams.ChangeStreamsRegistry

public class ChangeStreamsRegistry
extends Object

Registry to keep track of open change streasms wraps a map to easily allow to get corresponding SessionInfo that encapsulates db, coll, and opName

Author:

Andrea Di Cesare <andrea@softinstigate.com>

Constructor Summary

Constructors

Constructor	Description
ChangeStreamsRegistry()

Method Summary

Modifier and Type	Method	Description
boolean	containsKey(SessionKey key)
SessionInfo	get(SessionKey key)
static ChangeStreamsRegistry	getInstance()
Set<SessionKey>	getSessionKeysOnCollection(String db, String coll)
Set<SessionKey>	getSessionKeysOnDb(String db)
Set<SessionKey>	getSessionKeysOnOperation(SessionInfo db, String coll, String operation)
Set<SessionKey>	keySet()
SessionInfo	put(SessionKey key, SessionInfo info)
SessionInfo	remove(SessionKey key)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ChangeStreamsRegistry

public ChangeStreamsRegistry()

Method Detail

getInstance

public static ChangeStreamsRegistry getInstance()

get

public SessionInfo get(SessionKey key)

keySet

public Set<SessionKey> keySet()

put

public SessionInfo put(SessionKey key,
                       SessionInfo info)

containsKey

public boolean containsKey(SessionKey key)

remove

public SessionInfo remove(SessionKey key)

getSessionKeysOnDb

public Set<SessionKey> getSessionKeysOnDb(String db)

getSessionKeysOnCollection

public Set<SessionKey> getSessionKeysOnCollection(String db,
                                                  String coll)

getSessionKeysOnOperation

public Set<SessionKey> getSessionKeysOnOperation(SessionInfo db,
                                                 String coll,
                                                 String operation)