vertx / io.vertx.spi.cluster.ignite / IgniteClusterManager

IgniteClusterManager

open class IgniteClusterManager : ClusterManager

Apache Ignite based cluster manager.

Author
Andrey Gura

Constructors

<init>

IgniteClusterManager()

Default constructor. Cluster manager will get configuration from classpath.

IgniteClusterManager(cfg: IgniteConfiguration)

Creates cluster manager instance with given Ignite configuration. Use this constructor in order to configure cluster manager programmatically.

IgniteClusterManager(configFile: URL)

Creates cluster manager instance with given Spring XML configuration file. Use this constructor in order to configure cluster manager programmatically.

IgniteClusterManager(ignite: Ignite)

Creates cluster manager instance with given Ignite instance.

Properties

VERTX_CACHE_TEMPLATE_NAME

static val VERTX_CACHE_TEMPLATE_NAME: String

Functions

getAsyncMap

open fun <K : Any, V : Any> getAsyncMap(name: String, handler: Handler<AsyncResult<AsyncMap<K, V>>>): Unit

getAsyncMultiMap

open fun <K : Any, V : Any> getAsyncMultiMap(name: String, handler: Handler<AsyncResult<AsyncMultiMap<K, V>>>): Unit

getCounter

open fun getCounter(name: String, handler: Handler<AsyncResult<Counter>>): Unit

getIgniteInstance

open fun getIgniteInstance(): Ignite

Returns instance of Ignite.

getLockWithTimeout

open fun getLockWithTimeout(name: String, timeout: Long, handler: Handler<AsyncResult<Lock>>): Unit

getNodeID

open fun getNodeID(): String

getNodes

open fun getNodes(): MutableList<String>

getSyncMap

open fun <K : Any, V : Any> getSyncMap(name: String): MutableMap<K, V>

isActive

open fun isActive(): Boolean

join

open fun join(handler: Handler<AsyncResult<Void>>): Unit

leave

open fun leave(handler: Handler<AsyncResult<Void>>): Unit

nodeListener

open fun nodeListener(nodeListener: NodeListener): Unit

setVertx

open fun setVertx(vertx: Vertx): Unit