Make cache expiration time configurable (#5076)

apache · Mar 10, 2021 · 00642f7 · 00642f7
1 parent d8cf172
commit 00642f7
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/.../src/main/scala/org/apache/openwhisk/core/database/MultipleReadersSingleWriterCache.scala b/.../src/main/scala/org/apache/openwhisk/core/database/MultipleReadersSingleWriterCache.scala
@@ -94,6 +94,8 @@ trait MultipleReadersSingleWriterCache[W, Winfo] {
  /** Subclasses: Toggle this to enable/disable caching for your entity type. */
  protected val cacheEnabled = true
  protected val evictionPolicy: EvictionPolicy = AccessTime
+ protected val cacheExpirationTime: Long = 5
+ protected val cacheExpirationTimeUnit: TimeUnit = TimeUnit.MINUTES
  protected val fixedCacheSize = 0
 
  private object Entry {
@@ -452,8 +454,8 @@ trait MultipleReadersSingleWriterCache[W, Winfo] {
  .softValues()
 
  evictionPolicy match {
- case AccessTime => b.expireAfterAccess(5, TimeUnit.MINUTES)
- case _ => b.expireAfterWrite(5, TimeUnit.MINUTES)
+ case AccessTime => b.expireAfterAccess(cacheExpirationTime, cacheExpirationTimeUnit)
+ case _ => b.expireAfterWrite(cacheExpirationTime, cacheExpirationTimeUnit)
  }
 
  if (fixedCacheSize > 0) b.maximumSize(fixedCacheSize)