Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##: Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  lazy val cache: ClientCache

   Definition Classes

   GeodeCache

6.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws(classOf[java.lang.CloneNotSupportedException]) @native()

7.  def close(keepAlive: Boolean = false): Unit

   Definition Classes

   GeodeCache

8.  def closeContinuousQuery(queryName: Symbol): Option[Unit]
9.  final def configure(factory: ClientCacheFactory): ClientCacheFactory

   Pool subscription is mandatory for continuous query.

   Pool subscription is mandatory for continuous query.

   Attributes

   protected

   Definition Classes

   PoolSubscription → Geode → GeodeCache

10.  def continuousQuery[V <: AnyRef](queryName: Symbol, query: String)(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Source[V, Future[Done]]

    Shapeless powered implicit serializer.

11.  def continuousQuery[V <: AnyRef](queryName: Symbol, query: String, serializer: PekkoPdxSerializer[V]): Source[V, Future[Done]]
12.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

13.  def equals(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef → Any

14.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.Throwable])

15.  def flow[K, V <: AnyRef](settings: RegionSettings[K, V])(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Flow[V, V, NotUsed]

    Shapeless powered implicit serializer.

    Shapeless powered implicit serializer.

    Definition Classes

    Geode

16.  def flow[K, V <: AnyRef](settings: RegionSettings[K, V], serializer: PekkoPdxSerializer[V]): Flow[V, V, NotUsed]

    Definition Classes

    Geode

17.  final def getClass(): Class[_ <: AnyRef]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

18.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

19.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

20.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

21.  final def newCacheFactory(): ClientCacheFactory

    Return ClientCacheFactory:

    Return ClientCacheFactory:

    • with PDX support
    • configured by sub classes
    • customized by client application

    Attributes

    protected

    Definition Classes

    GeodeCache

22.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

23.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

24.  def query[V <: AnyRef](query: String)(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Source[V, Future[Done]]

    Shapeless powered implicit serializer.

    Shapeless powered implicit serializer.

    Definition Classes

    Geode

25.  def query[V <: AnyRef](query: String, serializer: PekkoPdxSerializer[V]): Source[V, Future[Done]]

    Definition Classes

    Geode

26.  def registerPDXSerializer[V](pdxSerializer: PdxSerializer, clazz: Class[V]): Unit

    Attributes

    protected

    Definition Classes

    GeodeCache

27.  def sink[K, V <: AnyRef](settings: RegionSettings[K, V])(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Sink[V, Future[Done]]

    Shapeless powered implicit serializer.

    Shapeless powered implicit serializer.

    Definition Classes

    Geode

28.  def sink[K, V <: AnyRef](settings: RegionSettings[K, V], serializer: PekkoPdxSerializer[V]): Sink[V, Future[Done]]

    Definition Classes

    Geode

29.  final def synchronized[T0](arg0: => T0): T0

    Definition Classes

    AnyRef

30.  def toString(): String

    Definition Classes

    AnyRef → Any

31.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

32.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

33.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException]) @native()