Skip to content

Commit 2db6777

Browse files
committed
Made generic the logstash serialization function
1 parent 333787a commit 2db6777

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

caso/messenger/logstash.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ def push(self, records):
7070
try:
7171
for record in records:
7272
#serialization of record
73-
rec=record.logstash_message()
73+
rec=record.serialization_message()
7474
#cASO timestamp added to each record
7575
rec['caso-timestamp']=ct
7676
#Send the record to LS

caso/record.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ def ssm_message(self):
4949
raise NotImplementedError("Method not implemented")
5050

5151

52-
def logstash_message(self):
52+
def serialization_message(self):
5353
"""Render record as the expected logstash message."""
5454
opts = {
5555
"by_alias": True,

0 commit comments

Comments
 (0)