in storehaus-memcache/src/main/scala/com/twitter/storehaus/memcache/MemcacheStore.scala [58:80]
def apply(
client: Client, ttl: Duration = DEFAULT_TTL, flag: Int = DEFAULT_FLAG): MemcacheStore =
new MemcacheStore(client, ttl, flag)
def defaultClient(
name: String,
nodeString: String,
retries: Int = DEFAULT_RETRIES,
timeout: Duration = DEFAULT_TIMEOUT,
hostConnectionLimit: Int = DEFAULT_CONNECTION_LIMIT): Client = {
Memcached.client
.withLabel(name)
.withRequestTimeout(timeout)
.withTransport
.connectTimeout(timeout)
.configured(Retries.Policy(RetryPolicy.tries(retries)))
.configured(TimeoutFilter.Param(timeout))
.configured(TimeoutFactory.Param(timeout))
.configured(Transport.Liveness.param.default.copy(readTimeout = timeout))
.configured(DefaultPool.Param.param.default.copy(high = hostConnectionLimit))
.newTwemcacheClient(nodeString)
}