client = $client; $this->config = $config; $this->log = $this->config->logger; $this->setBackoff(); $this->setSerializer(); $this->setCompression(); if (RelayConnector::supports('get-meta')) { $this->supportsGetWithMeta = true; } } /** * Returns statistics about Relay. * * Bypasses the `command()` method to avoid log spam. * * @return array */ public function stats() { return Relay::stats(); } /** * Returns the number of keys cached in memory for the current connection. * * @return int|float */ public function keysInMemory() { $stats = $this->memoize('stats'); $endpoints = (array) $this->endpointId(); $keys = 0; foreach ($stats['endpoints'] as $id => $data) { if (in_array($id, $endpoints)) { $keys += array_sum(array_map(function ($connection) { return $connection['keys'][$this->config->database] ?? 0; }, $data['connections'] ?? [])) ?: 0; } } return $keys; } /** * Flushes the Relay memory for the current FPM pool if needed. * * @param float $flushRequestedAt * @param int $database * @return void */ public function maybeFlushRelayMemory($flushRequestedAt, $database) { $endpoints = (array) $this->endpointId(); foreach ($endpoints as $endpoint) { $flushedAt = $this->lastMemoryFlush($endpoint ?: null, $database); if ($flushedAt < $flushRequestedAt) { $this->flushMemory($endpoint ?: null, $database); } } } }