Packages

object ConnectionManager

Source
ConnectionManager.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ConnectionManager
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def basic[F[_], A <: Connection[F]](builder: client.ConnectionBuilder[F, A])(implicit arg0: Sync[F]): ConnectionManager[F, A]

    Create a ConnectionManager that creates new connections on each request

    Create a ConnectionManager that creates new connections on each request

    builder

    generator of new connections

  2. def pool[F[_], A <: Connection[F]](builder: client.ConnectionBuilder[F, A], maxTotal: Int, maxWaitQueueLimit: Int, maxConnectionsPerRequestKey: (RequestKey) ⇒ Int, responseHeaderTimeout: Duration, requestTimeout: Duration, executionContext: ExecutionContext)(implicit arg0: Concurrent[F]): F[ConnectionManager[F, A]]

    Create a ConnectionManager that will attempt to recycle connections

    Create a ConnectionManager that will attempt to recycle connections

    builder

    generator of new connections

    maxTotal

    max total connections

    maxWaitQueueLimit

    maximum number requests waiting for a connection at any specific time

    maxConnectionsPerRequestKey

    Map of RequestKey to number of max connections

    executionContext

    ExecutionContext where async operations will execute