| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889 |
- <?php
- /*
- * This file is part of the Monolog package.
- *
- * (c) Jordi Boggiano <j.boggiano@seld.be>
- *
- * For the full copyright and license information, please view the LICENSE
- * file that was distributed with this source code.
- */
- namespace Monolog\Formatter;
- use Elastica\Document;
- /**
- * Format a log message into an Elastica Document
- *
- * @author Jelle Vink <jelle.vink@gmail.com>
- */
- class ElasticaFormatter extends NormalizerFormatter
- {
- /**
- * @var string Elastic search index name
- */
- protected $index;
- /**
- * @var string Elastic search document type
- */
- protected $type;
- /**
- * @param string $index Elastic Search index name
- * @param string $type Elastic Search document type
- */
- public function __construct($index, $type)
- {
- // elasticsearch requires a ISO 8601 format date with optional millisecond precision.
- parent::__construct('Y-m-d\TH:i:s.uP');
- $this->index = $index;
- $this->type = $type;
- }
- /**
- * {@inheritdoc}
- */
- public function format(array $record)
- {
- $record = parent::format($record);
- return $this->getDocument($record);
- }
- /**
- * Getter index
- * @return string
- */
- public function getIndex()
- {
- return $this->index;
- }
- /**
- * Getter type
- * @return string
- */
- public function getType()
- {
- return $this->type;
- }
- /**
- * Convert a log message into an Elastica Document
- *
- * @param array $record Log message
- * @return Document
- */
- protected function getDocument($record)
- {
- $document = new Document();
- $document->setData($record);
- $document->setType($this->type);
- $document->setIndex($this->index);
- return $document;
- }
- }
|