Documentation

ElasticsearchHandler extends AbstractProcessingHandler
in package

Elasticsearch handler

Tags
link

Simple usage example:

$client = \Elasticsearch\ClientBuilder::create() ->setHosts($hosts) ->build();

$options = array( 'index' => 'elastic_index_name', 'type' => 'elastic_doc_type', ); $handler = new ElasticsearchHandler($client, $options); $log = new Logger('application'); $log->pushHandler($handler);

author

Avtandil Kikabidze akalongman@gmail.com

Table of Contents

$bubble  : mixed
$client  : Client
$formatter  : FormatterInterface
$level  : mixed
$options  : array<string|int, mixed>
$processors  : mixed
__construct()  : mixed
__destruct()  : mixed
close()  : mixed
Closes the handler.
getBubble()  : bool
Gets the bubbling behavior.
getFormatter()  : FormatterInterface
Gets the formatter.
getLevel()  : int
Gets minimum logging level at which this handler will be triggered.
getOptions()  : array<string|int, mixed>
Getter options
handle()  : mixed
{@inheritdoc}
handleBatch()  : void
{@inheritdoc}
isHandling()  : bool
Checks whether the given record will be handled by this handler.
popProcessor()  : callable
Removes the processor on top of the stack and returns it.
pushProcessor()  : self
Adds a processor in the stack.
reset()  : mixed
setBubble()  : self
Sets the bubbling behavior.
setFormatter()  : HandlerInterface
{@inheritdoc}
setLevel()  : self
Sets minimum logging level at which this handler will be triggered.
bulkSend()  : void
Use Elasticsearch bulk API to send list of documents
createExceptionFromError()  : RuntimeException
Creates elasticsearch exception from error array
createExceptionFromResponses()  : RuntimeException
Creates elasticsearch exception from responses array
getDefaultFormatter()  : FormatterInterface
{@inheritDoc}
processRecord()  : array<string|int, mixed>
Processes a record.
write()  : void
Writes the record down to the log of the implementing handler

Properties

Methods

__construct()

public __construct(Client $client[, array<string|int, mixed> $options = [] ][, string|int $level = Logger::DEBUG ][, bool $bubble = true ]) : mixed
Parameters
$client : Client

Elasticsearch Client object

$options : array<string|int, mixed> = []

Handler configuration

$level : string|int = Logger::DEBUG

The minimum logging level at which this handler will be triggered

$bubble : bool = true

Whether the messages that are handled can bubble up the stack or not

Return values
mixed

close()

Closes the handler.

public close() : mixed

This will be called automatically when the object is destroyed

Return values
mixed

getBubble()

Gets the bubbling behavior.

public getBubble() : bool
Return values
bool

true means that this handler allows bubbling. false means that bubbling is not permitted.

getLevel()

Gets minimum logging level at which this handler will be triggered.

public getLevel() : int
Return values
int

getOptions()

Getter options

public getOptions() : array<string|int, mixed>
Return values
array<string|int, mixed>

handle()

{@inheritdoc}

public handle(array<string|int, mixed> $record) : mixed
Parameters
$record : array<string|int, mixed>
Return values
mixed

handleBatch()

{@inheritdoc}

public handleBatch(array<string|int, mixed> $records) : void
Parameters
$records : array<string|int, mixed>
Return values
void

isHandling()

Checks whether the given record will be handled by this handler.

public isHandling(array<string|int, mixed> $record) : bool
Parameters
$record : array<string|int, mixed>

Partial log record containing only a level key

Return values
bool

popProcessor()

Removes the processor on top of the stack and returns it.

public popProcessor() : callable
Return values
callable

pushProcessor()

Adds a processor in the stack.

public pushProcessor(mixed $callback) : self
Parameters
$callback : mixed
Return values
self

setBubble()

Sets the bubbling behavior.

public setBubble(bool $bubble) : self
Parameters
$bubble : bool

true means that this handler allows bubbling. false means that bubbling is not permitted.

Return values
self

setLevel()

Sets minimum logging level at which this handler will be triggered.

public setLevel(int|string $level) : self
Parameters
$level : int|string

Level or level name

Return values
self

bulkSend()

Use Elasticsearch bulk API to send list of documents

protected bulkSend(array<string|int, mixed> $records) : void
Parameters
$records : array<string|int, mixed>
Tags
throws
RuntimeException
Return values
void

createExceptionFromError()

Creates elasticsearch exception from error array

protected createExceptionFromError(array<string|int, mixed> $error) : RuntimeException
Parameters
$error : array<string|int, mixed>
Return values
RuntimeException

createExceptionFromResponses()

Creates elasticsearch exception from responses array

protected createExceptionFromResponses(array<string|int, mixed> $responses) : RuntimeException

Only the first error is converted into an exception.

Parameters
$responses : array<string|int, mixed>

returned by $this->client->bulk()

Return values
RuntimeException

processRecord()

Processes a record.

protected processRecord(array<string|int, mixed> $record) : array<string|int, mixed>
Parameters
$record : array<string|int, mixed>
Return values
array<string|int, mixed>

write()

Writes the record down to the log of the implementing handler

protected write(array<string|int, mixed> $record) : void
Parameters
$record : array<string|int, mixed>
Return values
void

Search results