package client
- Alphabetic
- By Inheritance
- client
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- trait BaseMethodBuilder[T] extends AnyRef
A base interface for protocol-specific
MethodBuilderimplementations.A base interface for protocol-specific
MethodBuilderimplementations. Acts as a template forMethodBuilderpattern and provides the documentation for common methods. - case class DefaultPool[Req, Rep](low: Int = 0, high: Int = Int.MaxValue, bufferSize: Int = 0, idleTime: Duration = Duration.Top, maxWaiters: Int = Int.MaxValue, timer: Timer = DefaultTimer) extends (StatsReceiver) => Transformer[Req, Rep] with Product with Serializable
Create a watermark pool backed by a caching pool.
Create a watermark pool backed by a caching pool. This is the default pooling setup of Finagle.
- low
The low watermark used in the Watermark pool. If there is sufficient request concurrency, no fewer connections will be maintained by the pool.
- high
The high watermark. The pool will not maintain more connections than this.
- bufferSize
Specifies the size of the lock-free buffer in front of the pool configuration. Skipped if 0.
- idleTime
The amount of idle time for which a connection is cached. This is applied to connections that number greater than the low watermark but fewer than the high.
- maxWaiters
The maximum number of connection requests that are queued when the connection concurrency exceeds the high watermark.
- class EndpointerModule[Req, Rep] extends Module[ServiceFactory[Req, Rep]]
A module that hooks in a
ServiceFactorythat directly makes connections, intended to be used as the lastServiceFactoryin the stack, the endpointer. - trait EndpointerStackClient[Req, Rep, This <: EndpointerStackClient[Req, Rep, This]] extends StackClient[Req, Rep] with Parameterized[This] with CommonParams[This] with ClientParams[This] with WithClientAdmissionControl[This] with WithClientTransport[This] with WithClientSession[This] with WithSessionQualifier[This]
The standard template implementation for com.twitter.finagle.client.StackClient.
The standard template implementation for com.twitter.finagle.client.StackClient.
- See also
The user guide for further details on Finagle clients and their configuration.
StackClient.newStack for the default modules used by Finagle clients.
- final class MethodBuilder[Req, Rep] extends Parameterized[MethodBuilder[Req, Rep]]
- See also
methodBuildermethods on client protocols, such asHttp.ClientorThriftMux.Clientfor an entry point.
- trait ServicePerEndpointBuilder[Req, Rep, ServicePerEndpoint <: Filterable[ServicePerEndpoint]] extends AnyRef
ServicePerEndpointBuilder creates
ServicePerEndpointtyped interfaces from underlyingService[Req, Rep]typed services. - trait StackBasedClient[Req, Rep] extends Client[Req, Rep] with Parameterized[StackBasedClient[Req, Rep]] with Transformable[StackBasedClient[Req, Rep]]
- trait StackClient[Req, Rep] extends StackBasedClient[Req, Rep] with Parameterized[StackClient[Req, Rep]] with Transformable[StackClient[Req, Rep]]
- trait StdStackClient[Req, Rep, This <: StdStackClient[Req, Rep, This]] extends EndpointerStackClient[Req, Rep, This]
- type Transformer[Req, Rep] = (ServiceFactory[Req, Rep]) => ServiceFactory[Req, Rep]
Transform a service factory stack.
- trait Transporter[In, Out, Ctx <: TransportContext] extends AnyRef
Transporters construct a
Future[Transport[In, Out, Context]].Transporters construct a
Future[Transport[In, Out, Context]].There is one Transporter assigned per remote peer. Transporters are symmetric to the server-side com.twitter.finagle.server.Listener, except that it isn't shared across remote peers..
Value Members
- object AddrMetadataExtraction
Extraction of com.twitter.finagle.Addr.Metadata from a com.twitter.finagle.factory.LoadBalancerFactory.Dest
- object BackupRequestFilter
- object DefaultPool extends Serializable
- object DynamicTimeout
Used for the creation of Stack modules that have dynamic timeouts.
Used for the creation of Stack modules that have dynamic timeouts.
- See also
TimeoutFilter
- object LatencyCompensation
Latency compensation enables the modification of connection, request, and session acquisition timeouts on a per-endpoint basis.
Latency compensation enables the modification of connection, request, and session acquisition timeouts on a per-endpoint basis. For instance, if a client has both network-local and trans-continental endpoints, a reasonable latency compensator might add the speed-of-light penalty when communicating with distant endpoints.
- object MethodBuilder
- object StackClient
- object StatsScoping
Stats scoping enabled the modification of the StatsReceiver scoping on a per-endpoint basis.
Stats scoping enabled the modification of the StatsReceiver scoping on a per-endpoint basis. For instance, if a client has endpoints in multiple zones, a scoper might add a per-zone scope.
- object Transporter
A collection of Stack.Params useful for configuring a com.twitter.finagle.client.Transporter.
- object useNackAdmissionFilter extends GlobalFlag[Boolean]