Interface EventBroker

  • All Known Implementing Classes:
    EventBrokerImpl

    public interface EventBroker
    • Method Detail

      • clear

        void clear()
      • getIdBasedEventMap

        Map<String,​step.plugins.events.Event> getIdBasedEventMap()
      • getIdBasedEventMap

        Map<String,​step.plugins.events.Event> getIdBasedEventMap​(int skip,
                                                                       int limit)
      • getCircuitBreakerThreshold

        long getCircuitBreakerThreshold()
      • setCircuitBreakerThreshold

        void setCircuitBreakerThreshold​(long circuitBreakerThreshold)
      • isUniqueGroupNameOn

        boolean isUniqueGroupNameOn()
      • setUniqueGroupNameOn

        void setUniqueGroupNameOn​(boolean hashedGroupNameOn)
      • getSize

        int getSize()
      • put

        step.plugins.events.Event put​(step.plugins.events.Event event)
                               throws Exception
        Main primitives, based on id
        Throws:
        Exception
      • get

        step.plugins.events.Event get​(String id)
      • peek

        step.plugins.events.Event peek​(String id)
      • peek

        step.plugins.events.Event peek​(String group,
                                       String name)
        Group primitives, adapted via lookup() to Id primitives
      • clearGroup

        void clearGroup​(String group)
      • get

        step.plugins.events.Event get​(String group,
                                      String name)
        Now using a sync-free optimistic version of the group lookup as an alternative to syncGroupOn
      • setAdvancedStatsOn

        void setAdvancedStatsOn​(boolean statsOn)
        Stats
      • getAdvancedStatsOn

        boolean getAdvancedStatsOn()
      • getCumulatedPuts

        long getCumulatedPuts()
      • getCumulatedGets

        long getCumulatedGets()
      • getCumulatedAttemptedGets

        long getCumulatedAttemptedGets()
      • getCumulatedAttemptedGroupGets

        long getCumulatedAttemptedGroupGets()
      • getCumulatedPeeks

        long getCumulatedPeeks()
      • getSizeWaterMark

        int getSizeWaterMark()
        Not fully reliable due to the nature of CHM
      • findOldestEvent

        step.plugins.events.Event findOldestEvent()
      • findYoungestEvent

        step.plugins.events.Event findYoungestEvent()
      • getSizeForGroup

        int getSizeForGroup​(String group)
      • findYoungestEventForGroup

        step.plugins.events.Event findYoungestEventForGroup​(String group)
      • findOldestEventForGroup

        step.plugins.events.Event findOldestEventForGroup​(String group)
      • clearStats

        void clearStats()
      • getGroupEvents

        Set<step.plugins.events.Event> getGroupEvents​(String group)
        Group access
      • getGroupEvents

        Set<step.plugins.events.Event> getGroupEvents​(String group,
                                                      int skip,
                                                      int limit)
      • getFullGroupBasedEventMap

        Map<String,​Set<step.plugins.events.Event>> getFullGroupBasedEventMap()
      • getGroupBasedEventMap

        Map<String,​Set<step.plugins.events.Event>> getGroupBasedEventMap​(int skip,
                                                                               int limit)
      • getDistinctGroupNames

        Set<String> getDistinctGroupNames()