class ThrottleFilterEvaluator extends EvaluatorFilter[ILoggingEvent]
Throttles logging events, so that no more than maxLoggedOverPeriod
unique events are logged over expiryPeriod
.
De-duplicates logging events over expiryPeriod.
Used to ensure that the interactive console remains usable even when the system is in a bad state and logging many errors.
Inspired by https://github.com/RotterdamLogisticsLab/logback-throttle/blob/master/src/main/kotlin/com/portofrotterdam/dbs/public/logback/throttle/Throttle.kt
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- ThrottleFilterEvaluator
- EvaluatorFilter
- AbstractMatcherFilter
- Filter
- LifeCycle
- ContextAwareBase
- ContextAware
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new ThrottleFilterEvaluator()
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def addError(arg0: String, arg1: Throwable): Unit
- Definition Classes
- ContextAwareBase → ContextAware
- def addError(arg0: String): Unit
- Definition Classes
- ContextAwareBase → ContextAware
- def addInfo(arg0: String, arg1: Throwable): Unit
- Definition Classes
- ContextAwareBase → ContextAware
- def addInfo(arg0: String): Unit
- Definition Classes
- ContextAwareBase → ContextAware
- def addStatus(arg0: Status): Unit
- Definition Classes
- ContextAwareBase → ContextAware
- def addWarn(arg0: String, arg1: Throwable): Unit
- Definition Classes
- ContextAwareBase → ContextAware
- def addWarn(arg0: String): Unit
- Definition Classes
- ContextAwareBase → ContextAware
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- def decide(arg0: ILoggingEvent): FilterReply
- Definition Classes
- EvaluatorFilter → Filter
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- val expiryPeriod: AtomicLong
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def getContext(): Context
- Definition Classes
- ContextAwareBase → ContextAware
- def getDeclaredOrigin(): AnyRef
- Attributes
- protected[spi]
- Definition Classes
- ContextAwareBase
- def getEvaluator(): EventEvaluator[ILoggingEvent]
- Definition Classes
- EvaluatorFilter
- def getName(): String
- Definition Classes
- Filter
- final def getOnMatch(): FilterReply
- Definition Classes
- AbstractMatcherFilter
- final def getOnMismatch(): FilterReply
- Definition Classes
- AbstractMatcherFilter
- def getStatusManager(): StatusManager
- Definition Classes
- ContextAwareBase
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isStarted(): Boolean
- Definition Classes
- Filter → LifeCycle
- val maxLoggedOverPeriod: AtomicLong
- val messageCache: TrieMap[String, Long]
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def setContext(arg0: Context): Unit
- Definition Classes
- ContextAwareBase → ContextAware
- def setEvaluator(arg0: EventEvaluator[ILoggingEvent]): Unit
- Definition Classes
- EvaluatorFilter
- def setExpiryPeriod(newValue: Long): Unit
- def setMaxLoggedOverPeriod(newValue: Long): Unit
- def setName(arg0: String): Unit
- Definition Classes
- Filter
- final def setOnMatch(arg0: FilterReply): Unit
- Definition Classes
- AbstractMatcherFilter
- final def setOnMismatch(arg0: FilterReply): Unit
- Definition Classes
- AbstractMatcherFilter
- def start(): Unit
- Definition Classes
- ThrottleFilterEvaluator → EvaluatorFilter → Filter → LifeCycle
- def stop(): Unit
- Definition Classes
- Filter → LifeCycle
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])