Packages

class Geode extends GeodeCache

Scala API: Geode client without server event subscription.

Source
Geode.scala
Linear Supertypes
GeodeCache, AnyRef, Any
Known Subclasses
PoolSubscription
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Geode
  2. GeodeCache
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new Geode(settings: GeodeSettings)

Value Members

  1. lazy val cache: ClientCache
    Definition Classes
    GeodeCache
  2. def close(keepAlive: Boolean = false): Unit
    Definition Classes
    GeodeCache
  3. 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.

  4. def flow[K, V <: AnyRef](settings: RegionSettings[K, V], serializer: PekkoPdxSerializer[V]): Flow[V, V, NotUsed]
  5. def query[V <: AnyRef](query: String)(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Source[V, Future[Done]]

    Shapeless powered implicit serializer.

  6. def query[V <: AnyRef](query: String, serializer: PekkoPdxSerializer[V]): Source[V, Future[Done]]
  7. 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.

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