1
0
mirror of https://github.com/meineerde/rackstash.git synced 2025-12-19 15:01:12 +00:00

Forward Logger#close and Logger#reopen to the Sink

This commit is contained in:
Holger Just 2017-07-21 16:44:11 +02:00
parent 40f920dafb
commit fc4a917b71
2 changed files with 24 additions and 1 deletions

View File

@ -102,6 +102,11 @@ module Rackstash
end end
end end
# (see Sink#close)
def close
@sink.close
end
# (see Sink#default_fields) # (see Sink#default_fields)
def default_fields def default_fields
@sink.default_fields @sink.default_fields
@ -133,6 +138,11 @@ module Rackstash
@sink.flows @sink.flows
end end
# (see Sink#reopen)
def reopen
@sink.reopen
end
# (see Buffer#tags) # (see Buffer#tags)
def tags def tags
buffer.tags buffer.tags

View File

@ -38,6 +38,13 @@ describe Rackstash::Logger do
end end
end end
describe '#close' do
it 'forwards to the sink' do
expect(logger.sink).to receive(:close)
logger.close
end
end
describe '#default_fields' do describe '#default_fields' do
it 'forwards to the sink' do it 'forwards to the sink' do
expect(logger.sink).to receive(:default_fields) expect(logger.sink).to receive(:default_fields)
@ -73,7 +80,6 @@ describe Rackstash::Logger do
end end
end end
describe '#formatter' do describe '#formatter' do
it 'defaults to a Rackstash::Formatter' do it 'defaults to a Rackstash::Formatter' do
expect(logger.formatter).to be_a Rackstash::Formatter expect(logger.formatter).to be_a Rackstash::Formatter
@ -160,6 +166,13 @@ describe Rackstash::Logger do
end end
end end
describe '#reopen' do
it 'forwards to the sink' do
expect(logger.sink).to receive(:reopen)
logger.reopen
end
end
describe '#sink' do describe '#sink' do
it 'returns the created sink' do it 'returns the created sink' do
expect(logger.sink).to be_a Rackstash::Sink expect(logger.sink).to be_a Rackstash::Sink