ClickhouseHostHealth

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. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

6. def entityToString(entity: ResponseEntity, encoding: HttpEncoding, progressQueue: Option[SourceQueue[QueryProgress]])(implicit materializer: Materializer, executionContext: ExecutionContext): Future[String]

   

   Attributes

   protected

   Definition Classes

   ClickhouseResponseParser

7. final def eq(arg0: AnyRef): Boolean

   

   Definition Classes

   AnyRef

8. def equals(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

9. def finalize(): Unit

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

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

10. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

11. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

12. def healthFlow(host: Uri)(implicit system: ActorSystem, materializer: Materializer, executionContext: ExecutionContext): Source[ClickhouseHostStatus, Cancellable]

    

    Creates a source which emits the health status at most every health-check.interval interval.

    Creates a source which emits the health status at most every health-check.interval interval. The source uses a cachedHostConnectionPool with a number of one maximum connections and one maximum open requests. This is configured on the provided actor system and assumes there is no other user of such a pool, so it will not be shared. This ensures the health checks will not affect the clients superPool in any way, and it will not fill the queue if one hosts hangs when returning the response. We also set the connection idle timeout to health-check.timeout to ensure that the pool will be blocked with on hanging request.

13. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

14. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

15. final def notify(): Unit

    

    Definition Classes

    AnyRef

16. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

17. def processClickhouseResponse(responseFuture: Future[HttpResponse], query: String, host: Uri, progressQueue: Option[SourceQueue[QueryProgress]])(implicit materializer: Materializer, executionContext: ExecutionContext): Future[String]

    

    Attributes

    protected

    Definition Classes

    ClickhouseResponseParser

18. def splitResponse(response: String): Seq[String]

    

    Attributes

    protected

    Definition Classes

    ClickhouseResponseParser

19. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

20. def toString(): String

    

    Definition Classes

    AnyRef → Any

21. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

23. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )