@@ -167,12 +167,12 @@ You can inject your own custom proc to handle buffer overflow in the event of co
167
167
import msgpack
168
168
from io import BytesIO
169
169
170
- def handler (pendings ):
170
+ def overflow_handler (pendings ):
171
171
unpacker = msgpack.Unpacker(BytesIO(pendings))
172
172
for unpacked in unpacker:
173
173
print (unpacked)
174
174
175
- logger = sender.FluentSender(' app' , host = ' host' , port = 24224 , buffer_overflow_handler = handler )
175
+ logger = sender.FluentSender(' app' , host = ' host' , port = 24224 , buffer_overflow_handler = overflow_handler )
176
176
177
177
You should handle any exception in handler. fluent-logger ignores exceptions from ``buffer_overflow_handler ``.
178
178
@@ -198,7 +198,7 @@ module.
198
198
199
199
logging.basicConfig(level = logging.INFO )
200
200
l = logging.getLogger(' fluent.test' )
201
- h = handler.FluentHandler(' app.follow' , host = ' host' , port = 24224 , buffer_overflow_handler = handler )
201
+ h = handler.FluentHandler(' app.follow' , host = ' host' , port = 24224 , buffer_overflow_handler = overflow_handler )
202
202
formatter = handler.FluentRecordFormatter(custom_format)
203
203
h.setFormatter(formatter)
204
204
l.addHandler(h)
@@ -228,7 +228,7 @@ You can inject your own custom proc to handle buffer overflow in the event of co
228
228
import msgpack
229
229
from io import BytesIO
230
230
231
- def handler (pendings ):
231
+ def overflow_handler (pendings ):
232
232
unpacker = msgpack.Unpacker(BytesIO(pendings))
233
233
for unpacked in unpacker:
234
234
print (unpacked)
@@ -264,7 +264,7 @@ A sample configuration ``logging.yaml`` would be:
264
264
host: localhost
265
265
port: 24224
266
266
tag: test.logging
267
- buffer_overflow_handler: handler
267
+ buffer_overflow_handler: overflow_handler
268
268
formatter: fluent_fmt
269
269
level: DEBUG
270
270
none:
0 commit comments