12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788 |
- <?php
- require 'SharedConfigurations.php';
- use Predis\Command\CommandInterface;
- use Predis\Connection\StreamConnection;
- class SimpleDebuggableConnection extends StreamConnection
- {
- private $tstart = 0;
- private $debugBuffer = array();
- public function connect()
- {
- $this->tstart = microtime(true);
- parent::connect();
- }
- private function storeDebug(CommandInterface $command, $direction)
- {
- $firtsArg = $command->getArgument(0);
- $timestamp = round(microtime(true) - $this->tstart, 4);
- $debug = $command->getId();
- $debug .= isset($firtsArg) ? " $firtsArg " : ' ';
- $debug .= "$direction $this";
- $debug .= " [{$timestamp}s]";
- $this->debugBuffer[] = $debug;
- }
- public function writeCommand(CommandInterface $command)
- {
- parent::writeCommand($command);
- $this->storeDebug($command, '->');
- }
- public function readResponse(CommandInterface $command)
- {
- $reply = parent::readResponse($command);
- $this->storeDebug($command, '<-');
- return $reply;
- }
- public function getDebugBuffer()
- {
- return $this->debugBuffer;
- }
- }
- $options = array(
- 'connections' => array(
- 'tcp' => 'SimpleDebuggableConnection',
- ),
- );
- $client = new Predis\Client($single_server, $options);
- $client->set('foo', 'bar');
- $client->get('foo');
- $client->info();
- print_r($client->getConnection()->getDebugBuffer());
|