Package step.plugins.event

Interface EventBroker

  • All Known Implementing Classes:
    EventBrokerImpl
    public interface EventBroker

    • Method Detail

      • clear

        void clear()

      • getIdBasedEventMap

        java.util.Map<java.lang.String,​step.plugins.events.Event> getIdBasedEventMap()

      • getIdBasedEventMap

        java.util.Map<java.lang.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 java.lang.Exception
        Main primitives, based on id
        Throws:
        java.lang.Exception

      • get

        step.plugins.events.Event get​(java.lang.String id)

      • peek

        step.plugins.events.Event peek​(java.lang.String id)

      • peek

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

      • clearGroup

        void clearGroup​(java.lang.String group)

      • get

        step.plugins.events.Event get​(java.lang.String group,
                              java.lang.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()

      • getStats

        java.util.Map<java.lang.String,​java.lang.Object> getStats()

      • getGroupStats

        java.util.Map<java.lang.String,​java.lang.Object> getGroupStats​(java.lang.String group)
        Parameters:
        group -
        Returns:

      • 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​(java.lang.String group)

      • findYoungestEventForGroup

        step.plugins.events.Event findYoungestEventForGroup​(java.lang.String group)

      • findOldestEventForGroup

        step.plugins.events.Event findOldestEventForGroup​(java.lang.String group)

      • clearStats

        void clearStats()

      • getGroupEvents

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

      • getGroupEvents

        java.util.Set<step.plugins.events.Event> getGroupEvents​(java.lang.String group,
                                                        int skip,
                                                        int limit)

      • getFullGroupBasedEventMap

        java.util.Map<java.lang.String,​java.util.Set<step.plugins.events.Event>> getFullGroupBasedEventMap()

      • getGroupBasedEventMap

        java.util.Map<java.lang.String,​java.util.Set<step.plugins.events.Event>> getGroupBasedEventMap​(int skip,
                                                                                                     int limit)

      • getDistinctGroupNames

        java.util.Set<java.lang.String> getDistinctGroupNames()