Package io.antmedia.datastore.db

Class RedisStore

java.lang.Object

io.antmedia.datastore.db.DataStore

io.antmedia.datastore.db.MapBasedDataStore

io.antmedia.datastore.db.RedisStore

public class RedisStore
extends MapBasedDataStore

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.slf4j.Logger	logger
private org.redisson.api.RMap<Object,Object>	p2pMap
(package private) org.redisson.api.RedissonClient	redisson
private org.redisson.api.RMap<Object,Object>	streamInfoMap

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
RedisStore(String redisConnectionUrl, String dbName)

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
boolean	createP2PConnection(P2PConnection conn)	Creates new P2PConnection
boolean	deleteP2PConnection(String streamId)	Deletes a P2PConnection
long	getLocalLiveBroadcastCount(String hostAddress)
List<Broadcast>	getLocalLiveBroadcasts(String hostAddress)
P2PConnection	getP2PConnection(String streamId)	Get the P2PConnection by streamId
List<StreamInfo>	getStreamInfoList(String streamId)	Returns stream info list added to db
int	resetBroadcasts(String hostAddress)	Resets the broadcasts in the database.
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, delete, deleteSubscriber, deleteToken, deleteVod, fetchUserVodList, get, getActiveBroadcastCount, getActiveBroadcastList, getActiveSubtracks, getActiveSubtracks, getActiveSubtracksCount, getBroadcastFromMap, getBroadcastList, getBroadcastListV2, getConferenceRoomMap, getConnectedSubscriberCount, getConnectedSubscribers, getConnectionEvents, getExternalStreamsList, getPartialBroadcastNumber, getPartialVodNumber, getReturningConnectionEventsList, getSubscriber, getSubscriberMetaData, getSubtrackCount, getSubtracks, getSubtracks, getToken, getTotalBroadcastNumber, getTotalVodNumber, getTotalWebRTCViewersCount, getVoD, getVodList, getVodListV2, hasSubtracks, listAllSubscribers, listAllTokens, putSubscriberMetaData, removeAllEndpoints, removeEndpoint, 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

logger

protected static org.slf4j.Logger logger

redisson

org.redisson.api.RedissonClient redisson

streamInfoMap

private org.redisson.api.RMap<Object,Object> streamInfoMap

p2pMap

private org.redisson.api.RMap<Object,Object> p2pMap

Constructor Details

RedisStore

public RedisStore(String redisConnectionUrl,
 String dbName)

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

resetBroadcasts

public int resetBroadcasts(String hostAddress)

Description copied from class: DataStore

Resets the broadcasts in the database. It sets number of viewers to zero. It also delete the stream if it's zombi stream

Overrides:

resetBroadcasts 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:

clearStreamInfoList

public void clearStreamInfoList(String streamId)

Description copied from class: DataStore

Remove the stream info list from db

Overrides:

clearStreamInfoList in class MapBasedDataStore

saveStreamInfo

public void saveStreamInfo(StreamInfo streamInfo)

Description copied from class: DataStore

Saves the stream info to the db

Overrides:

saveStreamInfo in class MapBasedDataStore

createP2PConnection

public boolean createP2PConnection(P2PConnection conn)

Description copied from class: DataStore

Creates new P2PConnection

Overrides:

createP2PConnection in class MapBasedDataStore

Parameters:

conn - - P2PConnection object

Returns:

boolean - success

deleteP2PConnection

public boolean deleteP2PConnection(String streamId)

Description copied from class: DataStore

Deletes a P2PConnection

Overrides:

deleteP2PConnection in class MapBasedDataStore

Returns:

boolean - success

getP2PConnection

public P2PConnection getP2PConnection(String streamId)

Description copied from class: DataStore

Get the P2PConnection by streamId

Overrides:

getP2PConnection in class MapBasedDataStore

Parameters:

streamId - - stream id for P2PConnection

Returns:

P2PConnection - if exist else null

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