thrift.codegen.async_client_pool

Utilities for asynchronously querying multiple servers, building on TAsyncClient.

Terminology note: The names of the artifacts defined in this module are derived from »client pool«, because they operate on a pool of TAsyncClients. However, from a architectural point of view, they often represent a pool of hosts a Thrift client application communicates with using RPC calls.

Members

Classes

TAsyncAggregator
class TAsyncAggregator(Interface)

Allows easily aggregating results from a number of TAsyncClients.

TAsyncClientPool
class TAsyncClientPool(Interface)

A TAsyncClientPoolBase implementation which queries multiple servers in a row until a request succeeds, the result of which is then returned.

TAsyncFastestClientPool
class TAsyncFastestClientPool(Interface)

A TAsyncClientPoolBase implementation which queries multiple servers at the same time and returns the first success response.

Functions

tAsyncAggregator
TAsyncAggregator!Interface tAsyncAggregator(TAsyncClientBase!Interface[] clients)

TAsyncAggregator construction helper to avoid having to explicitly specify the interface type, i.e. to allow the constructor being called using IFTI (see $(DMDBUG 6082, D Bugzilla enhancement request 6082)).

tAsyncClientPool
TAsyncClientPool!Interface tAsyncClientPool(TAsyncClientBase!Interface[] clients)

TAsyncClientPool construction helper to avoid having to explicitly specify the interface type, i.e. to allow the constructor being called using IFTI (see $(DMDBUG 6082, D Bugzilla enhancement request 6082)).

tAsyncFastestClientPool
TAsyncFastestClientPool!Interface tAsyncFastestClientPool(TAsyncClientBase!Interface[] clients)

TAsyncFastestClientPool construction helper to avoid having to explicitly specify the interface type, i.e. to allow the constructor being called using IFTI (see $(DMDBUG 6082, D Bugzilla enhancement request 6082)).

Interfaces

TAsyncClientPoolBase
interface TAsyncClientPoolBase(Interface)

Represents a generic client pool which implements TFutureInterface!Interface using multiple TAsyncClients.

Templates

isAccumulator
template isAccumulator(ValueType, alias fun)

Whether fun is a valid accumulator function for values of type ValueType.

Variables

defaultRpcFaultFilter
bool delegate(Exception) defaultRpcFaultFilter;
Undocumented in source.

Meta