Sha256: d141c6e43996c52837e71b318aefa337c1a890820e07fff8b66f1549ddb29428

Contents?: true

Size: 302 Bytes

Versions: 3

Compression:

Stored size: 302 Bytes

Contents

package org.embulk.filter.key_in_redis.redis

import org.slf4j.Logger

import scala.collection.mutable

case class Cache(loadFromStorage: () => mutable.Set[String])(
    implicit logger: Logger) {
  private val cache = loadFromStorage()
  def contains(value: String): Boolean = cache.contains(value)
}

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
embulk-filter-key_in_redis-0.1.3 src/main/scala/org/embulk/filter/key_in_redis/redis/Cache.scala
embulk-filter-key_in_redis-0.1.2 src/main/scala/org/embulk/filter/key_in_redis/redis/Cache.scala
embulk-filter-key_in_redis-0.1.1 src/main/scala/org/embulk/filter/key_in_redis/redis/Cache.scala