final case class PrepareCache(svc: Service[Request, Response], maxSize: Int, statsReceiver: StatsReceiver) extends ServiceProxy[Request, Response] with Product with Serializable
Caches statements that have been successfully prepared over the connection managed by the underlying service (a ClientDispatcher). This decreases the chances of leaking prepared statements and can simplify the implementation of prepared statements in the presence of a connection pool.
- Alphabetic
- By Inheritance
- PrepareCache
- Serializable
- Product
- Equals
- ServiceProxy
- Proxy
- Service
- Closable
- Function1
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def andThen[A](g: (Future[Response]) => A): (Request) => A
- Definition Classes
- Function1
- Annotations
- @unspecialized()
- def apply(request: Request): Future[Response]
This is the method to override/implement to create your own Service.
This is the method to override/implement to create your own Service.
- Definition Classes
- PrepareCache → ServiceProxy → Service → Function1
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def close(deadline: Time): Future[Unit]
- Definition Classes
- PrepareCache → ServiceProxy → Service → Closable
- def close(after: Duration): Future[Unit]
- Definition Classes
- Closable
- final def close(): Future[Unit]
- Definition Classes
- Closable
- def compose[A](g: (A) => Request): (A) => Future[Response]
- Definition Classes
- Function1
- Annotations
- @unspecialized()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(that: Any): Boolean
- Definition Classes
- Proxy → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- Proxy → Any
- final def isAvailable: Boolean
Determines whether this
Service
is available (can accept requests with a reasonable likelihood of success).Determines whether this
Service
is available (can accept requests with a reasonable likelihood of success).- Definition Classes
- Service
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def map[Req1](f: (Req1) => Request): Service[Req1, Response]
- Definition Classes
- Service
- val maxSize: Int
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- val self: Service[Request, Response]
- Definition Classes
- ServiceProxy → Proxy
- val statsReceiver: StatsReceiver
- def status: Status
The current availability Status of this
Service
.The current availability Status of this
Service
.- Definition Classes
- ServiceProxy → Service
- val svc: Service[Request, Response]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- ServiceProxy → Proxy → Service → Function1 → AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()