Package io.antmedia.datastore.db

Class MapDBStore

java.lang.Object

io.antmedia.datastore.db.DataStore

io.antmedia.datastore.db.MapBasedDataStore

io.antmedia.datastore.db.MapDBStore

public class MapDBStore
extends MapBasedDataStore

Field Summary

Fields

Modifier and Type	Field	Description
private AtomicBoolean	committing
private static final String	CONFERENCE_ROOM_MAP_NAME
private static final String	CONNECTION_EVENTS
private org.mapdb.DB	db
private static final String	DETECTION_MAP_NAME
protected static org.slf4j.Logger	logger
private static final String	MAP_NAME
private static final String	SUBSCRIBER
private static final String	SUBSCRIBER_METADATA
private long	timerId
private static final String	TOKEN
private io.vertx.core.Vertx	vertx
private static final String	VOD_MAP_NAME
private static final String	WEBRTC_VIEWER

Fields inherited from class io.antmedia.datastore.db.MapBasedDataStore

conferenceRoomMap, connectionEventsMap, dbName, detectionMap, gson, INCONSISTENCY_MESSAGE, map, subscriberMap, subscriberMetadataMap, tokenMap, vodMap, webRTCViewerMap

Fields inherited from class io.antmedia.datastore.db.DataStore

appSettings, available, MAX_ITEM_IN_ONE_LIST, REPLACE_CHARS_REGEX, TOTAL_WEBRTC_VIEWER_COUNT_CACHE_TIME, totalWebRTCViewerCount, totalWebRTCViewerCountLastUpdateTime

Constructor Summary

Constructors

Constructor	Description
MapDBStore(String dbName, io.vertx.core.Vertx vertx)

Method Summary

Modifier and Type	Method	Description
void	clearStreamInfoList(String streamId)	Remove the stream info list from db
void	close(boolean deleteDB)	Closes the database
long	getLocalLiveBroadcastCount(String hostAddress)
List<Broadcast>	getLocalLiveBroadcasts(String hostAddress)
List<StreamInfo>	getStreamInfoList(String streamId)	Returns stream info list added to db
void	saveStreamInfo(StreamInfo streamInfo)	Saves the stream info to the db

Methods inherited from class io.antmedia.datastore.db.MapBasedDataStore

addConnectionEvent, addEndpoint, addSubscriber, addVod, blockSubscriber, createP2PConnection, delete, deleteP2PConnection, deleteSubscriber, deleteToken, deleteVod, fetchUserVodList, get, getActiveBroadcastCount, getActiveBroadcastList, getActiveSubtracks, getActiveSubtracks, getActiveSubtracksCount, getBroadcastFromMap, getBroadcastList, getBroadcastListV2, getConferenceRoomMap, getConnectedSubscriberCount, getConnectedSubscribers, getConnectionEvents, getExternalStreamsList, getP2PConnection, getPartialBroadcastNumber, getPartialVodNumber, getReturningConnectionEventsList, getSubscriber, getSubscriberMetaData, getSubtrackCount, getSubtracks, getSubtracks, getToken, getTotalBroadcastNumber, getTotalVodNumber, getTotalWebRTCViewersCount, getVoD, getVodList, getVodListV2, hasSubtracks, listAllSubscribers, listAllTokens, putSubscriberMetaData, removeAllEndpoints, removeEndpoint, resetBroadcasts, resetSubscribersConnectedStatus, revokeSubscribers, revokeTokens, save, saveToken, setBroadcastToMap, setMp4Muxing, setWebMMuxing, updateBroadcastFields, updateDASHViewerCountLocal, updateHLSViewerCountLocal, updateRtmpViewerCountLocal, updateStatus, updateStreamMetaData, updateVoDProcessStatus, updateWebRTCViewerCountLocal, validateToken

Methods inherited from class io.antmedia.datastore.db.DataStore

addQueryTime, addSubscriberConnectionEvent, get, getActiveBroadcastCount, getActiveBroadcastList, getAverageQueryTimeMs, getBroadcastCount, getConnectionEventListFromCollection, getExecutedQueryCount, getSubscriber, getToken, getTotalBroadcastNumber, getTotalVodNumber, getTotalWebRTCViewersCount, getVoD, getVodListV2, handleConnectionEvent, isAvailable, isSubscriberConnected, listAllSubscribers, listAllTokens, saveBroadcast, searchOnServer, searchOnServerVod, setAppSettings, showWarningIfElapsedTimeIsMoreThanThreshold, sortAndCropBroadcastList, sortAndCropVodList, updateDASHViewerCount, updateHLSViewerCount, updateRtmpViewerCount, updateStreamInfo, updateSubscriberBitrateEvent, updateWebRTCViewerCount

Methods inherited from class java.lang.Object

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

Field Details

db

private org.mapdb.DB db

vertx

private io.vertx.core.Vertx vertx

timerId

private long timerId

committing

private AtomicBoolean committing

logger

protected static org.slf4j.Logger logger

MAP_NAME

private static final String MAP_NAME

See Also:

• Constant Field Values

VOD_MAP_NAME

private static final String VOD_MAP_NAME

See Also:

• Constant Field Values

DETECTION_MAP_NAME

private static final String DETECTION_MAP_NAME

See Also:

• Constant Field Values

TOKEN

private static final String TOKEN

See Also:

• Constant Field Values

SUBSCRIBER

private static final String SUBSCRIBER

See Also:

• Constant Field Values

CONFERENCE_ROOM_MAP_NAME

private static final String CONFERENCE_ROOM_MAP_NAME

See Also:

• Constant Field Values

WEBRTC_VIEWER

private static final String WEBRTC_VIEWER

See Also:

• Constant Field Values

SUBSCRIBER_METADATA

private static final String SUBSCRIBER_METADATA

See Also:

• Constant Field Values

CONNECTION_EVENTS

private static final String CONNECTION_EVENTS

See Also:

• Constant Field Values

Constructor Details

MapDBStore

public MapDBStore(String dbName,
 io.vertx.core.Vertx vertx)

Method Details

close

public void close(boolean deleteDB)

Description copied from class: DataStore

Closes the database

Specified by:

close in class DataStore

Parameters:

deleteDB - if it's true, it also deletes the db and closes

getLocalLiveBroadcastCount

public long getLocalLiveBroadcastCount(String hostAddress)

Specified by:

getLocalLiveBroadcastCount in class DataStore

getLocalLiveBroadcasts

public List<Broadcast> getLocalLiveBroadcasts(String hostAddress)

Specified by:

getLocalLiveBroadcasts in class DataStore

clearStreamInfoList

public void clearStreamInfoList(String streamId)

Description copied from class: DataStore

Remove the stream info list from db

Overrides:

clearStreamInfoList in class MapBasedDataStore

getStreamInfoList

public List<StreamInfo> getStreamInfoList(String streamId)

Description copied from class: DataStore

Returns stream info list added to db

Overrides:

getStreamInfoList in class MapBasedDataStore

Returns:

saveStreamInfo

public void saveStreamInfo(StreamInfo streamInfo)

Description copied from class: DataStore

Saves the stream info to the db

Overrides:

saveStreamInfo in class MapBasedDataStore