NSL KV/xyz.noisif.nsl.kv.jedis/JedisServer

JedisServer

open class JedisServer : KvServer, ScriptableKeyValueStore

Constructors

private constructor(builder: JedisServer.Builder)

Types

open class Builder : KvServer.AbstractBuilder<JedisServer.Builder>

Properties

private val clientFactory: JedisClientFactory

componentProvider

protected val componentProvider: ComponentProvider

private val initialized: AtomicBoolean

private val kvScripts: Set<KvScript>

kvScriptsBasePath

private val kvScriptsBasePath: String

protected val log: Logger

protected val nodes: Set<HostPort>

protected val password: String

private val poolMaxIdle: Int

private val poolMaxTotal: Int

private val poolMinIdle: Int

private open var redisClient: UnifiedJedis

registeredSubscribers

private val registeredSubscribers: Collection<KvSubscriber<out Any>>

private val running: AtomicBoolean

scriptCacheManager

private open var scriptCacheManager: ScriptCacheManager

Functions

awaitSubscribers

open fun awaitSubscribers(timeoutMs: Long)

open fun builder(): JedisServer.Builder

fun close()

createRegistrar

protected open fun createRegistrar(): PubSubRegistrar

open fun del(key: KvKey, keyParams: Array<Any>)

open fun eval(scriptKey: KvScript, keys: List<String>, args: List<String>): Any

open fun eval(scriptKey: KvScript): Any

open fun eval(scriptKey: KvScript, keys: List<String>): Any

open fun get(key: KvKey, keyParams: Array<Any>): String

onKvServerStart

protected fun onKvServerStart()

protected abstract fun onStart()

protected fun onStart()

protected fun onStop()

open fun publish(channel: KvChannel, message: String, channelParams: Array<Any>)

open fun publishBinary(channel: KvChannel, message: Array<Byte>, channelParams: Array<Any>)

open fun set(key: KvKey, value: String, keyParams: Array<Any>)

open fun setWithTtl(key: KvKey, value: String, keyParams: Array<Any>)

fun start()

translateException

protected open fun translateException(ex: Exception): RuntimeException