.\" -*- mode: troff; coding: utf-8 -*- .\" Automatically generated by Pod::Man v6.0.2 (Pod::Simple 3.45) .\" .\" Standard preamble: .\" ======================================================================== .de Sp \" Vertical space (when we can't use .PP) .if t .sp .5v .if n .sp .. .de Vb \" Begin verbatim text .ft CW .nf .ne \\$1 .. .de Ve \" End verbatim text .ft R .fi .. .\" \*(C` and \*(C' are quotes in nroff, nothing in troff, for use with C<>. .ie n \{\ . ds C` "" . ds C' "" 'br\} .el\{\ . ds C` . ds C' 'br\} .\" .\" Escape single quotes in literal strings from groff's Unicode transform. .ie \n(.g .ds Aq \(aq .el .ds Aq ' .\" .\" If the F register is >0, we'll generate index entries on stderr for .\" titles (.TH), headers (.SH), subsections (.SS), items (.Ip), and index .\" entries marked with X<> in POD. Of course, you'll have to process the .\" output yourself in some meaningful fashion. .\" .\" Avoid warning from groff about undefined register 'F'. .de IX .. .nr rF 0 .if \n(.g .if rF .nr rF 1 .if (\n(rF:(\n(.g==0)) \{\ . if \nF \{\ . de IX . tm Index:\\$1\t\\n%\t"\\$2" .. . if !\nF==2 \{\ . nr % 0 . nr F 2 . \} . \} .\} .rr rF .\" .\" Required to disable full justification in groff 1.23.0. .if n .ds AD l .\" ======================================================================== .\" .IX Title "DlfConverterProcess 3pm" .TH DlfConverterProcess 3pm 2025-09-28 "Lire 2.1.1" "LogReport's Lire Documentation" .\" For nroff, turn off justification. Always turn off hyphenation; it makes .\" way too many mistakes in technical documents. .if n .ad l .nh .SH NAME Lire::DlfConverterProcess \- Object that controls the DLF conversion process .SH SYNOPSIS .IX Header "SYNOPSIS" .Vb 3 \& use Lire::ImportJob; \& use Lire::DlfStore; \& use Lire::DlfConverterProcess; \& \& my $src = new Lire::ImportJob( "file", \*(Aqpattern\*(Aq => "/var/log/messages" ); \& my $store = Lire::DlfStore\->open( "store" ); \& \& my $process = new Lire::DlfConverterProcess( $src, $store ); \& \& $process\->run_import_job(); \& \& print "Log lines read: ", $process\->line_count(), "\en"; \& print "DLF records created: ", $process\->dlf_count, "\en"; \& print "Errors encountered: ", $process\->errors_count, "\en"; \& print "Ignored records: ", $process\->ignored_count,"\en"; .Ve .SH DESCRIPTION .IX Header "DESCRIPTION" This object encapsulates the Lire DLF conversion process. It takes as parameter a Lire::ImportJob and a Lire::DlfStore. It will setup the converter and will converter the content of Lire::ImportJob to DLF which will be saved in the Lire::DlfStore. .PP The object provides the API to the converter. Methods are also available to query information on the conversion process. .ie n .SH "new( $job, $store );" .el .SH "new( \f(CW$job\fP, \f(CW$store\fP );" .IX Header "new( $job, $store );" Create a Lire::DlfConverterProcess that will be used to import the log specified in Lire::ImportJob into DLF records which will be stored into Lire::DlfStore. .SS "run_import_job( [$time] )" .IX Subsection "run_import_job( [$time] )" Import the log data from ImportJob as DLF. This method will throw an exception if it is called more than once. The \f(CW$time\fR parameter will be used to determine the time window covered by period. It defaults to the current time. .SS \fBjob_id()\fP .IX Subsection "job_id()" Returns the job identifier associated to this process. .SS \fBdlf_store()\fP .IX Subsection "dlf_store()" Returns the Lire::DlfStore in which this conversion process is storing the DLF records. .SS \fBimport_job()\fP .IX Subsection "import_job()" Returns the Lire::ImportJob upon which this conversion process is operating. .SS \fBline_count()\fP .IX Subsection "line_count()" Returns the number of lines processed. This will 0 in case the DLF converter process file and not log lines. During a processing, this is always equals to the line that is currently being converted. .SS \fBdlf_count()\fP .IX Subsection "dlf_count()" Returns the number of DLF records created. .SS \fBerror_count()\fP .IX Subsection "error_count()" Returns the number of errors encountered in the conversion process. .SS \fBignored_count()\fP .IX Subsection "ignored_count()" Returns the number of records which were ignored in the conversion process. .SS \fBsaved_count()\fP .IX Subsection "saved_count()" Returns the number of lines which were saved for later processing. .SH "API FOR THE DLF CONVERTERS" .IX Header "API FOR THE DLF CONVERTERS" This is the object that encapsulates the Dlf implementation and hides the complexitity of the storage framework from the DLF converter. It offers the following methods to the DLf converter. .ie n .SS "write_dlf( $schema, $dlf )" .el .SS "write_dlf( \f(CW$schema\fP, \f(CW$dlf\fP )" .IX Subsection "write_dlf( $schema, $dlf )" This writes the \f(CW$dlf\fR DLF record conforming the \f(CW$schema\fR\*(Aqs schema in the Lire::DlfStore. The schema is the schema\*(Aqs name (e.g. \*(Aqwww\*(Aq). \f(CW$dlf\fR is an hash reference. Keys are the schema\*(Aqs field name. Undefined value means that this field isn\*(Aqt available in that record. .ie n .SS "save_log_line( $line )" .el .SS "save_log_line( \f(CW$line\fP )" .IX Subsection "save_log_line( $line )" Method that should be used to save \f(CW$line\fR for a future processing run of the converter on the same Lire::ImportJob. .ie n .SS "ignored_log_line( $line, [ $reason ] )" .el .SS "ignored_log_line( \f(CW$line\fP, [ \f(CW$reason\fP ] )" .IX Subsection "ignored_log_line( $line, [ $reason ] )" Method that can be used by the Lire::DlfConverter to report that the \&\*(Aq$line\*(Aq log line was ignored during that processing. The reason why the line was ignored can be given in \f(CW$reason\fR. For example, syslog\-based converter should use that method to report lines that are for another \*(Aqservice\*(Aq than theirs. .ie n .SS "error( $error_msg, [ $line ] );" .el .SS "error( \f(CW$error_msg\fP, [ \f(CW$line\fP ] );" .IX Subsection "error( $error_msg, [ $line ] );" Method that should be used by the Lire::DlfConveter to report that an error was encountered when processing the Lire::ImportJob. \f(CW$error_msg\fR should be used to report the nature of the error. The \f(CW$line\fR parameter should be used by converter operating on lines to associate the error message to a particular line. .SH "SEE ALSO" .IX Header "SEE ALSO" \&\fBLire::DlfStore\fR\|(3pm) \fBLire::DlfConverter\fR\|(3pm) .SH AUTHOR .IX Header "AUTHOR" Francis J. Lacoste .SH VERSION .IX Header "VERSION" \&\f(CW$Id:\fR DlfConverterProcess.pm,v 1.18 2006/07/23 13:16:28 vanbaal Exp $ .SH COPYRIGHT .IX Header "COPYRIGHT" Copyright (C) 2002\-2004 Stichting LogReport Foundation LogReport@LogReport.org .PP This file is part of Lire. .PP Lire is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. .PP This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. .PP You should have received a copy of the GNU General Public License along with this program (see COPYING); if not, check with http://www.gnu.org/copyleft/gpl.html.