Log handler sends log events to a kafka server. More...

Inheritance diagram for MediaWiki\Logger\Monolog\KafkaHandler:

Collaboration diagram for MediaWiki\Logger\Monolog\KafkaHandler:

[legend]

Public Member Functions
	__construct (Produce $produce, array $options, $level=Logger::DEBUG, $bubble=true)

	handleBatch (array $batch)

Static Public Member Functions
static	factory ( $kafkaServers, array $options=[], $level=Logger::DEBUG, $bubble=true)
	Constructs the necessary support objects and returns a KafkaHandler instance.

Protected Member Functions
	addMessages ( $channel, array $records)
	Adds records for a channel to the Kafka client internal queue.

	getRandomPartition ( $topic)

	send ()
	Send any records in the kafka client internal queue.

	warning ( $message, array $context=[])

	write (array $record)

Protected Attributes
array	$options
	Optional handler configuration.

array	$partitions = []
	Map from topic name to partition this request produces to.

Produce	$produce
	Sends requests to kafka.

Static Private Attributes
static array	$defaultOptions
	defaults for constructor options

Detailed Description

Log handler sends log events to a kafka server.

Constructor options array arguments:

alias: map from monolog channel to kafka topic name. When no alias exists the topic "monolog_$channel" will be used.
swallowExceptions: Swallow exceptions that occur while talking to kafka. Defaults to false.
logExceptions: Log exceptions talking to kafka here. Either null, the name of a channel to log to, or an object implementing FormatterInterface. Defaults to null.

Requires the nmred/kafka-php library, version >= 1.3.0

Since: 1.26

Author: Erik Bernhardson ebern.nosp@m.hard.nosp@m.son@w.nosp@m.ikim.nosp@m.edia..nosp@m.org

Note: © 2015 Erik Bernhardson and Wikimedia Foundation.

Definition at line 49 of file KafkaHandler.php.

Constructor & Destructor Documentation

◆ __construct()

MediaWiki\Logger\Monolog\KafkaHandler::__construct	(	Produce	$produce,
		array	$options,
			$level = Logger::DEBUG,
			$bubble = true )

Parameters

Produce	$produce	Kafka instance to produce through
array	$options	optional handler configuration
int	$level	The minimum logging level at which this handler will be triggered
bool	$bubble	Whether the messages that are handled can bubble up the stack or not

Definition at line 81 of file KafkaHandler.php.

References MediaWiki\Logger\Monolog\KafkaHandler\$options, and MediaWiki\Logger\Monolog\KafkaHandler\$produce.

Member Function Documentation

◆ addMessages()

MediaWiki\Logger\Monolog\KafkaHandler::addMessages	(		$channel,
		array	$records )

protected

Adds records for a channel to the Kafka client internal queue.

Parameters

string	$channel	Name of Monolog channel records belong to
array	$records	List of records to append

Definition at line 256 of file KafkaHandler.php.

References MediaWiki\Logger\Monolog\KafkaHandler\getRandomPartition().

Referenced by MediaWiki\Logger\Monolog\KafkaHandler\handleBatch(), and MediaWiki\Logger\Monolog\KafkaHandler\write().

◆ factory()

static MediaWiki\Logger\Monolog\KafkaHandler::factory	(		$kafkaServers,
		array	$options = [],
			$level = Logger::DEBUG,
			$bubble = true )

static

Constructs the necessary support objects and returns a KafkaHandler instance.

Parameters

string[]	$kafkaServers
array	$options
int	$level	The minimum logging level at which this handle will be triggered
bool	$bubble	Whether the messages that are handled can bubble the stack or not

Returns: KafkaHandler

Definition at line 99 of file KafkaHandler.php.

References MediaWiki\Logger\Monolog\KafkaHandler\$options, MediaWiki\Logger\Monolog\KafkaHandler\$produce, and MediaWiki\Logger\LoggerFactory\getInstance().

◆ getRandomPartition()

MediaWiki\Logger\Monolog\KafkaHandler::getRandomPartition ( $topic )

protected

Parameters

string $topic Name of topic to get partition for

Returns: int|null The random partition to produce to for this request, or null if a partition could not be determined.

Definition at line 219 of file KafkaHandler.php.

References MediaWiki\Logger\Monolog\KafkaHandler\$partitions, and MediaWiki\Logger\Monolog\KafkaHandler\warning().

Referenced by MediaWiki\Logger\Monolog\KafkaHandler\addMessages().

◆ handleBatch()

MediaWiki\Logger\Monolog\KafkaHandler::handleBatch ( array $batch )

Definition at line 143 of file KafkaHandler.php.

References MediaWiki\Logger\Monolog\KafkaHandler\addMessages(), and MediaWiki\Logger\Monolog\KafkaHandler\send().

◆ send()

MediaWiki\Logger\Monolog\KafkaHandler::send ( )

protected

Send any records in the kafka client internal queue.

Definition at line 172 of file KafkaHandler.php.

References $response, and MediaWiki\Logger\Monolog\KafkaHandler\warning().

Referenced by MediaWiki\Logger\Monolog\KafkaHandler\handleBatch(), and MediaWiki\Logger\Monolog\KafkaHandler\write().

◆ warning()

MediaWiki\Logger\Monolog\KafkaHandler::warning	(		$message,
		array	$context = [] )

protected

Parameters

string	$message	PSR3 compatible message string
array	$context	PSR3 compatible log context

Returns: bool true if caller should ignore warning

Definition at line 269 of file KafkaHandler.php.

References $context.

Referenced by MediaWiki\Logger\Monolog\KafkaHandler\getRandomPartition(), and MediaWiki\Logger\Monolog\KafkaHandler\send().

◆ write()

MediaWiki\Logger\Monolog\KafkaHandler::write ( array $record )

protected

Definition at line 133 of file KafkaHandler.php.

References MediaWiki\Logger\Monolog\KafkaHandler\addMessages(), and MediaWiki\Logger\Monolog\KafkaHandler\send().

Member Data Documentation

◆ $defaultOptions

array MediaWiki\Logger\Monolog\KafkaHandler::$defaultOptions

staticprivate

Initial value:

= [
        'alias' => [], 
        'swallowExceptions' => false, 
        'logExceptions' => null, 
        'requireAck' => 0,
    ]

defaults for constructor options

Definition at line 68 of file KafkaHandler.php.

◆ $options

array MediaWiki\Logger\Monolog\KafkaHandler::$options

protected

Optional handler configuration.

Definition at line 58 of file KafkaHandler.php.

Referenced by MediaWiki\Logger\Monolog\KafkaHandler\__construct(), and MediaWiki\Logger\Monolog\KafkaHandler\factory().

◆ $partitions

array MediaWiki\Logger\Monolog\KafkaHandler::$partitions = []

protected

Map from topic name to partition this request produces to.

Definition at line 63 of file KafkaHandler.php.

Referenced by MediaWiki\Logger\Monolog\KafkaHandler\getRandomPartition().

◆ $produce

Produce MediaWiki\Logger\Monolog\KafkaHandler::$produce

protected

Sends requests to kafka.

Definition at line 53 of file KafkaHandler.php.

Referenced by MediaWiki\Logger\Monolog\KafkaHandler\__construct(), and MediaWiki\Logger\Monolog\KafkaHandler\factory().

The documentation for this class was generated from the following file:

includes/debug/logger/monolog/KafkaHandler.php

Public Member Functions

Static Public Member Functions

Protected Member Functions

Protected Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ __construct()

Member Function Documentation

◆ addMessages()

◆ factory()

◆ getRandomPartition()

◆ handleBatch()

◆ send()

◆ warning()

◆ write()

Member Data Documentation

◆ $defaultOptions

◆ $options

◆ $partitions

◆ $produce