NSL KV/xyz.noisif.nsl.kv/KvServer

KvServer

abstract class KvServer : IdempotentService, KeyValueStore, PubSubBroadcaster

Inheritors

JedisServer

Constructors

KvServer

protected constructor(builder: KvServer.AbstractBuilder<out Any>)

Types

AbstractBuilder

protected abstract class AbstractBuilder<B : KvServer.AbstractBuilder<B>?>

Properties

componentProvider

protected val componentProvider: ComponentProvider

initialized

private val initialized: AtomicBoolean

log

protected val log: Logger

nodes

protected val nodes: Set<HostPort>

password

protected val password: String

registeredSubscribers

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

running

private val running: AtomicBoolean

Functions

awaitSubscribers

open fun awaitSubscribers(timeoutMs: Long)

fun close()

createRegistrar

protected abstract fun createRegistrar(): PubSubRegistrar

del

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

get

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

onKvServerStart

protected abstract fun onKvServerStart()

onStart

protected fun onStart()

onStop

protected abstract fun onStop()

publish

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

publishBinary

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

registerSet

private open fun <T> registerSet(payloadClass: Class<T>, typeRef: TypeReference<KvSubscriber<T>>, exactRegistrar: Consumer<KvSubscriber<T>>, patternRegistrar: Consumer<KvSubscriber<T>>): Int

set

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

setWithTtl

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

start

fun start()

translateException

protected open fun translateException(ex: Exception): RuntimeException