trait PoolSubscription extends Geode
Value Members
- final def !=(arg0: Any): Boolean
- final def ##: Int
- final def ==(arg0: Any): Boolean
- final def asInstanceOf[T0]: T0
- lazy val cache: ClientCache
- def clone(): AnyRef
- def close(keepAlive: Boolean = false): Unit
- def closeContinuousQuery(queryName: Symbol): Option[Unit]
- final def configure(factory: ClientCacheFactory): ClientCacheFactory
- def continuousQuery[V <: AnyRef](queryName: Symbol, query: String)(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Source[V, Future[Done]]
- def continuousQuery[V <: AnyRef](queryName: Symbol, query: String, serializer: PekkoPdxSerializer[V]): Source[V, Future[Done]]
- final def eq(arg0: AnyRef): Boolean
- def equals(arg0: AnyRef): Boolean
- def finalize(): Unit
- def flow[K, V <: AnyRef](settings: RegionSettings[K, V])(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Flow[V, V, NotUsed]
- def flow[K, V <: AnyRef](settings: RegionSettings[K, V], serializer: PekkoPdxSerializer[V]): Flow[V, V, NotUsed]
- final def getClass(): Class[_ <: AnyRef]
- def hashCode(): Int
- final def isInstanceOf[T0]: Boolean
- final def ne(arg0: AnyRef): Boolean
- final def newCacheFactory(): ClientCacheFactory
- final def notify(): Unit
- final def notifyAll(): Unit
- def query[V <: AnyRef](query: String)(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Source[V, Future[Done]]
- def query[V <: AnyRef](query: String, serializer: PekkoPdxSerializer[V]): Source[V, Future[Done]]
- def registerPDXSerializer[V](pdxSerializer: PdxSerializer, clazz: Class[V]): Unit
- def sink[K, V <: AnyRef](settings: RegionSettings[K, V])(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Sink[V, Future[Done]]
- def sink[K, V <: AnyRef](settings: RegionSettings[K, V], serializer: PekkoPdxSerializer[V]): Sink[V, Future[Done]]
- final def synchronized[T0](arg0: => T0): T0
- def toString(): String
- final def wait(): Unit
- final def wait(arg0: Long, arg1: Int): Unit
- final def wait(arg0: Long): Unit
Inherited from Geode
Value Members
- def flow[K, V <: AnyRef](settings: RegionSettings[K, V])(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Flow[V, V, NotUsed]
- def flow[K, V <: AnyRef](settings: RegionSettings[K, V], serializer: PekkoPdxSerializer[V]): Flow[V, V, NotUsed]
- def query[V <: AnyRef](query: String)(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Source[V, Future[Done]]
- def query[V <: AnyRef](query: String, serializer: PekkoPdxSerializer[V]): Source[V, Future[Done]]
- def sink[K, V <: AnyRef](settings: RegionSettings[K, V])(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Sink[V, Future[Done]]
- def sink[K, V <: AnyRef](settings: RegionSettings[K, V], serializer: PekkoPdxSerializer[V]): Sink[V, Future[Done]]
Inherited from GeodeCache
Inherited from Any
Value Members
- final def asInstanceOf[T0]: T0
- final def isInstanceOf[T0]: Boolean
Ungrouped
- final def !=(arg0: Any): Boolean
- final def ##: Int
- final def ==(arg0: Any): Boolean
- final def asInstanceOf[T0]: T0
- lazy val cache: ClientCache
- def clone(): AnyRef
- def close(keepAlive: Boolean = false): Unit
- def closeContinuousQuery(queryName: Symbol): Option[Unit]
- final def configure(factory: ClientCacheFactory): ClientCacheFactory
- def continuousQuery[V <: AnyRef](queryName: Symbol, query: String)(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Source[V, Future[Done]]
- def continuousQuery[V <: AnyRef](queryName: Symbol, query: String, serializer: PekkoPdxSerializer[V]): Source[V, Future[Done]]
- final def eq(arg0: AnyRef): Boolean
- def equals(arg0: AnyRef): Boolean
- def finalize(): Unit
- def flow[K, V <: AnyRef](settings: RegionSettings[K, V])(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Flow[V, V, NotUsed]
- def flow[K, V <: AnyRef](settings: RegionSettings[K, V], serializer: PekkoPdxSerializer[V]): Flow[V, V, NotUsed]
- final def getClass(): Class[_ <: AnyRef]
- def hashCode(): Int
- final def isInstanceOf[T0]: Boolean
- final def ne(arg0: AnyRef): Boolean
- final def newCacheFactory(): ClientCacheFactory
- final def notify(): Unit
- final def notifyAll(): Unit
- def query[V <: AnyRef](query: String)(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Source[V, Future[Done]]
- def query[V <: AnyRef](query: String, serializer: PekkoPdxSerializer[V]): Source[V, Future[Done]]
- def registerPDXSerializer[V](pdxSerializer: PdxSerializer, clazz: Class[V]): Unit
- def sink[K, V <: AnyRef](settings: RegionSettings[K, V])(implicit tag: ClassTag[V], enc: PdxEncoder[V], dec: PdxDecoder[V]): Sink[V, Future[Done]]
- def sink[K, V <: AnyRef](settings: RegionSettings[K, V], serializer: PekkoPdxSerializer[V]): Sink[V, Future[Done]]
- final def synchronized[T0](arg0: => T0): T0
- def toString(): String
- final def wait(): Unit
- final def wait(arg0: Long, arg1: Int): Unit
- final def wait(arg0: Long): Unit