IcansLoggingComponent

A PHP Component providing: - a Flume-Handler to write to a flume-node - a FilterInterface to write filters which can be added to the handler and filter the data - a PostProcessorInterface to write a postprocessor which can enrich the logged data - a Timer to measure execution times - a ProgressInformationInterface with default implementation to have progress messages in a CLI Command, _(*1)

Installation: You can use composer to install the component from packagist: icans/logging-component, _(*2)

Usages:, _(*3)

ThriftFlumeHandler:, _(*4)

<?php $host = localhost $port = 9129 $thriftSocket = new Thrift\Transport\TSocket($host, $port); $thriftTransport = new Thrift\Transport\TBufferedTransport($thriftSocket); $thriftProtocol = new Thrift\Protocol\TBinaryProtocolAccelerated($thriftTransport); $thriftFlumeClient = new ICANS\Component\IcansLoggingComponent\Flume\ThriftFlumeEventServerClient($thriftProtocol), _(*5)

$thriftFlumeProcessingHandler = new ThriftFlumeProcessingHandler($thriftTransport, $thriftFlumeClient);, _(*6)

$formatter = new Monolog\Formatter\JsonFormatter(); $thriftFlumeProcessingHandler->setFormatter($formatter);, _(*7)

//the processor has to implement the ICANS\Component\IcansLoggingComponent\Api\V1\PostProcessorInterface $processor = new myPostProcessor(); $thriftFlumeProcessingHandler->pushProcessor($processor);, _(*8)

$emptyFilter = new ICANS\Component\IcansLoggingComponent\Filter\EmptyFilter(); $thriftFlumeProcessingHandler->addFilter($emptyFilter);, _(*9)

$recordData = array('testdata' => 'test');, _(*10)

//will write to the flume node $thriftFlumeProcessingHandler->write($recordData);, _(*11)

RabbitMqHandler:, _(*12)

<?php, _(*13)