mirror of
https://github.com/rsyslog/rsyslog.git
synced 2025-12-21 07:50:41 +01:00
fe8d317c1b
Now, the full batch is passed down to the rule, which then enqueues the elements as single messages. Note that this code has some known defects and needs more changes until it is correct again. This is primarily a commit to be able to return to a known-(somewhat)-good state.
67 lines
2.6 KiB
C
67 lines
2.6 KiB
C
/* The ruleset object.
|
|
*
|
|
* This implements rulesets within rsyslog.
|
|
*
|
|
* Copyright 2009 Rainer Gerhards and Adiscon GmbH.
|
|
*
|
|
* This file is part of the rsyslog runtime library.
|
|
*
|
|
* The rsyslog runtime library is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU Lesser General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* The rsyslog runtime library 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 Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public License
|
|
* along with the rsyslog runtime library. If not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
* A copy of the GPL can be found in the file "COPYING" in this distribution.
|
|
* A copy of the LGPL can be found in the file "COPYING.LESSER" in this distribution.
|
|
*/
|
|
#ifndef INCLUDED_RULESET_H
|
|
#define INCLUDED_RULESET_H
|
|
|
|
#include "queue.h"
|
|
#include "linkedlist.h"
|
|
|
|
/* the ruleset object */
|
|
struct ruleset_s {
|
|
BEGINobjInstance; /* Data to implement generic object - MUST be the first data element! */
|
|
linkedList_t llRules; /* this is NOT a pointer - no typo here ;) */
|
|
uchar *pszName; /* name of our ruleset */
|
|
qqueue_t *pQueue; /* "main" message queue, if the ruleset has its own (else NULL) */
|
|
parserList_t *pParserLst;/* list of parsers to use for this ruleset */
|
|
};
|
|
|
|
/* interfaces */
|
|
BEGINinterface(ruleset) /* name must also be changed in ENDinterface macro! */
|
|
INTERFACEObjDebugPrint(ruleset);
|
|
rsRetVal (*DebugPrintAll)(void);
|
|
rsRetVal (*Construct)(ruleset_t **ppThis);
|
|
rsRetVal (*ConstructFinalize)(ruleset_t __attribute__((unused)) *pThis);
|
|
rsRetVal (*Destruct)(ruleset_t **ppThis);
|
|
rsRetVal (*IterateAllActions)(rsRetVal (*pFunc)(void*, void*), void* pParam);
|
|
rsRetVal (*DestructAllActions)(void);
|
|
rsRetVal (*AddRule)(ruleset_t *pThis, rule_t **ppRule);
|
|
rsRetVal (*SetName)(ruleset_t *pThis, uchar *pszName);
|
|
rsRetVal (*ProcessBatch)(batch_t*);
|
|
rsRetVal (*GetRuleset)(ruleset_t **ppThis, uchar*);
|
|
rsRetVal (*SetDefaultRuleset)(uchar*);
|
|
rsRetVal (*SetCurrRuleset)(uchar*);
|
|
ruleset_t* (*GetCurrent)(void);
|
|
qqueue_t* (*GetRulesetQueue)(ruleset_t*);
|
|
/* v3, 2009-11-04 */
|
|
parserList_t* (*GetParserList)(msg_t *);
|
|
ENDinterface(ruleset)
|
|
#define rulesetCURR_IF_VERSION 4 /* increment whenever you change the interface structure! */
|
|
|
|
|
|
/* prototypes */
|
|
PROTOTYPEObj(ruleset);
|
|
|
|
#endif /* #ifndef INCLUDED_RULESET_H */
|