Package org.restheart.mongodb.handlers.changestreams

Class ChangeStreamWorkers

java.lang.Object

org.restheart.mongodb.handlers.changestreams.ChangeStreamWorkers

public class ChangeStreamWorkers
extends Object

Registry to keep track of ChangeStreamWorkers

Author:

Andrea Di Cesare <andrea@softinstigate.com>

Constructor Summary

Constructors

Constructor	Description
ChangeStreamWorkers()

Method Summary

Modifier and Type	Method	Description
Optional<ChangeStreamWorker>	get(ChangeStreamWorkerKey key)
static ChangeStreamWorkers	getInstance()
Set<ChangeStreamWorker>	getWorkersOnCollection(String db, String coll)
Set<ChangeStreamWorker>	getWorkersOnDb(String db)
boolean	put(ChangeStreamWorker csw)
boolean	remove(ChangeStreamWorkerKey key)

Methods inherited from class java.lang.Object

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

Constructor Details

ChangeStreamWorkers

public ChangeStreamWorkers()

Method Details

getInstance

public static ChangeStreamWorkers getInstance()

get

public Optional<ChangeStreamWorker> get(ChangeStreamWorkerKey key)

put

public boolean put(ChangeStreamWorker csw)

remove

public boolean remove(ChangeStreamWorkerKey key)

getWorkersOnDb

public Set<ChangeStreamWorker> getWorkersOnDb(String db)

getWorkersOnCollection

public Set<ChangeStreamWorker> getWorkersOnCollection(String db,
 String coll)