Package io.antmedia.statistic

Class ViewerStats

java.lang.Object
io.antmedia.statistic.ViewerStats
Direct Known Subclasses:
DashViewerStats, HlsViewerStats
public class ViewerStats extends Object

  • Field Details

    • logger

      protected static org.slf4j.Logger logger

    • vertx

      protected io.vertx.core.Vertx vertx

    • HLS_TYPE

      public static final String HLS_TYPE
      See Also:

    • DASH_TYPE

      public static final String DASH_TYPE
      See Also:

    • VOD_TYPE

      public static final String VOD_TYPE
      See Also:

    • type

      private String type

    • dataStore

      private DataStore dataStore

    • dataStoreFactory

      protected DataStoreFactory dataStoreFactory

    • DEFAULT_TIME_PERIOD_FOR_VIEWER_COUNT

      public static final int DEFAULT_TIME_PERIOD_FOR_VIEWER_COUNT
      See Also:

    • appName

      protected String appName

    • timePeriodMS

      private int timePeriodMS
      Time period in milliseconds to check if viewer is dropped

    • streamsViewerMap

      Map<String,Map<String,Long>> streamsViewerMap

    • sessionId2subscriberId

      Map<String,String> sessionId2subscriberId

    • increaseCounterMap

      Map<String,Integer> increaseCounterMap

    • lock

      private Object lock

    • serverSettings

      protected ServerSettings serverSettings

    • timeoutMS

      protected int timeoutMS
      Time out value in milliseconds, it is regarded as user is not watching stream if last request time is older than timeout value

  • Constructor Details

    • ViewerStats

      public ViewerStats()

  • Method Details

    • registerNewViewer

      public void registerNewViewer(String streamId, String sessionId, String subscriberId)

    • resetViewerMap

      public void resetViewerMap(String streamID, String type)

    • getViewerCount

      public int getViewerCount(String streamId)

    • getTotalViewerCount

      public int getTotalViewerCount()

    • setDataStore

      public void setDataStore(DataStore dataStore)

    • getDataStoreFactory

      public DataStoreFactory getDataStoreFactory()

    • setDataStoreFactory

      public void setDataStoreFactory(DataStoreFactory dataStoreFactory)

    • getDataStore

      public DataStore getDataStore()

    • getIncreaseCounterMap

      public int getIncreaseCounterMap(String streamId)

    • getTimeoutMSFromSettings

      public static int getTimeoutMSFromSettings(AppSettings settings, int defaultValue, String type)

    • setTimePeriodMS

      public void setTimePeriodMS(int timePeriodMS)

    • getTimePeriodMS

      public int getTimePeriodMS()

    • getTimeoutMS

      public int getTimeoutMS()

    • getSessionId2subscriberId

      public Map<String,String> getSessionId2subscriberId()

    • setSessionId2subscriberId

      public void setSessionId2subscriberId(Map<String,String> sessionId2subscriberId)

    • setVertx

      public void setVertx(io.vertx.core.Vertx vertx)

    • updateViewerCountProcess

      public void updateViewerCountProcess(String type)

    • isStreaming

      public boolean isStreaming(Broadcast broadcast)

    • setServerSettings

      public void setServerSettings(ServerSettings serverSettings)

    • getType

      public String getType()

    • setType

      public void setType(String type)