1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
#############################################################################
# Copyright (c) 2022 Balazs Scheidler <bazsi77@gmail.com>
#
# This 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 2.1 of the License, or (at your option) any later version.
#
# This 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 this library; if not, write to the Free Software
# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
#
# As an additional exemption you are allowed to compile & link against the
# OpenSSL libraries as published by the OpenSSL project. See the file
# COPYING for details.
#
#############################################################################
# pylint: disable=function-redefined
try:
from _syslogng import LogDestination, LogDestinationResult
except ImportError:
import warnings
from enum import Enum, auto
warnings.warn("You have imported the syslogng package outside of syslog-ng, "
"thus some of the functionality is not available. "
"Defining fake classes for those exported by the underlying syslog-ng code")
LogDestination = object
class LogDestinationResult(Enum):
DROP = auto()
ERROR = auto()
SUCCESS = auto()
QUEUED = auto()
NOT_CONNECTED = auto()
class LogDestination(LogDestination):
DROP = LogDestinationResult.DROP
ERROR = LogDestinationResult.ERROR
SUCCESS = LogDestinationResult.SUCCESS
QUEUED = LogDestinationResult.QUEUED
NOT_CONNECTED = LogDestinationResult.NOT_CONNECTED
def open(self):
"""Open a connection to the target service"""
return True
def close(self):
"""Close the connection to the target service"""
def is_opened(self):
"""Check if the connection to the target is able to receive messages"""
return True
def init(self, options):
"""Initialize this log element
This method is called when the syslog-ng configuration is
initialized. You can prevent the configuration to be accepted by
returning False, in which case you should log why that was the case.
The same object can be initalized multiple times in case the
configuration reload operation fails in syslog-ng:
1) init() when the config is first initialized
2) deinit() as a preparation for reload
3) initialization of the new config fails for some reason (any one
object can cause it to fail)
4) init() again, as syslog-ng reverts to the old config in such cases.
Args:
options:
is a dictionary that contains options passed using the
options() parameter of the python() destination
Returns:
bool: True if successful, False otherwise
"""
return True
def deinit(self):
"""Deinitialize this log element
This method is called when the syslog-ng configuration is being shut
down.
"""
def send(self, msg):
"""Send a message to the target service
This method is invoked by the underlying C code to dispatch a
message to the target service.
Args:
msg (LogMessage): message to be sent
Returns:
int: one value from the LogDestinationResult enum
"""
raise NotImplementedError
|
