Skip to content

Commit

Permalink
Add cpu usage processor
Browse files Browse the repository at this point in the history
  • Loading branch information
JohJohan committed Jun 20, 2023
1 parent b05bf55 commit b5197e6
Show file tree
Hide file tree
Showing 3 changed files with 110 additions and 0 deletions.
1 change: 1 addition & 0 deletions doc/02-handlers-formatters-processors.md
Original file line number Diff line number Diff line change
Expand Up @@ -160,6 +160,7 @@
## Processors

- [_PsrLogMessageProcessor_](https://github.com/Seldaek/monolog/blob/main/src/Monolog/Processor/PsrLogMessageProcessor.php): Processes a log record's message according to PSR-3 rules, replacing `{foo}` with the value from `$context['foo']`.
- [_CPUUsageProcessor_](https://github.com/Seldaek/monolog/blob/main/src/Monolog/Processor/CPUUsageProcessor.php): Adds the current avg cpu use to a log record.
- [_ClosureContextProcessor_](https://github.com/Seldaek/monolog/blob/main/src/Monolog/Processor/ClosureContextProcessor.php): Allows delaying the creation of context data by setting a Closure in context which is called when the log record is used
- [_IntrospectionProcessor_](https://github.com/Seldaek/monolog/blob/main/src/Monolog/Processor/IntrospectionProcessor.php): Adds the line/file/class/method from which the log call originated.
- [_WebProcessor_](https://github.com/Seldaek/monolog/blob/main/src/Monolog/Processor/WebProcessor.php): Adds the current request URI, request method and client IP to a log record.
Expand Down
66 changes: 66 additions & 0 deletions src/Monolog/Processor/CPUUsageProcessor.php
Original file line number Diff line number Diff line change
@@ -0,0 +1,66 @@
<?php declare(strict_types=1);

/*
* This file is part of the Monolog package.
*
* (c) Jordi Boggiano <[email protected]>
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/

namespace Monolog\Processor;

use Monolog\LogRecord;

/**
* Injects sys_getloadavg in all records @see https://www.php.net/manual/en/function.sys-getloadavg.php
*
* @author Johan Vlaar <[email protected]>
*/
class CPUUsageProcessor implements ProcessorInterface
{
public const AVG_SYSTEM_LOAD_1_MINUTE = 0;
public const AVG_SYSTEM_LOAD_5_MINUTE = 1;
public const AVG_SYSTEM_LOAD_15_MINUTE = 2;

public const AVAILABLE_AVG_SYSTEM_LOAD = [
self::AVG_SYSTEM_LOAD_1_MINUTE,
self::AVG_SYSTEM_LOAD_5_MINUTE,
self::AVG_SYSTEM_LOAD_15_MINUTE,
];

/**
* @var int
*/
protected $avgSystemLoad;

/**
* @param int $avgSystemLoad
*/
public function __construct(int $avgSystemLoad = self::AVG_SYSTEM_LOAD_1_MINUTE)
{
if (!in_array($avgSystemLoad, self::AVAILABLE_AVG_SYSTEM_LOAD, true)) {
throw new \InvalidArgumentException(sprintf('Invalid average system load: `%s`', $avgSystemLoad));
}
$this->avgSystemLoad = $avgSystemLoad;
}

/**
* {@inheritDoc}
*/
public function __invoke(LogRecord $record): LogRecord
{
if (!function_exists('sys_getloadavg')) {
return $record;
}
$usage = sys_getloadavg();
if (false === $usage) {
return $record;
}

$record['extra']['cpu_usage'] = $usage[$this->avgSystemLoad];

return $record;
}
}
43 changes: 43 additions & 0 deletions tests/Monolog/Processor/CPUUsageProcessorTest.php
Original file line number Diff line number Diff line change
@@ -0,0 +1,43 @@
<?php declare(strict_types=1);

/*
* This file is part of the Monolog package.
*
* (c) Jordi Boggiano <[email protected]>
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/

namespace Monolog\Processor;

use Monolog\Test\TestCase;

/**
* Injects sys_getloadavg in all records @see https://www.php.net/manual/en/function.sys-getloadavg.php
*
* @author Johan Vlaar <[email protected]>
*/
class CPUUsageProcessorTest extends TestCase
{
/**
* @covers Monolog\Processor\CPUUsageProcessor::__invoke
*/
public function testProcessor()
{
$processor = new CPUUsageProcessor();
$record = $processor($this->getRecord());
$this->assertArrayHasKey('cpu_usage', $record->extra);
$this->assertIsFloat($record->extra['cpu_usage']);
}

/**
* @covers Monolog\Processor\CPUUsageProcessor::__invoke
*/
public function testProcessorWithInvalidAvgSystemLoad()
{
$this->expectException(\InvalidArgumentException::class);
$this->expectExceptionMessage('Invalid average system load: `3`');
new CPUUsageProcessor(3);
}
}

0 comments on commit b5197e6

Please sign in to comment.