diff --git a/lib/rackstash/logger.rb b/lib/rackstash/logger.rb index c2c94b2..e7c88ad 100644 --- a/lib/rackstash/logger.rb +++ b/lib/rackstash/logger.rb @@ -102,6 +102,11 @@ module Rackstash end end + # (see Sink#close) + def close + @sink.close + end + # (see Sink#default_fields) def default_fields @sink.default_fields @@ -133,6 +138,11 @@ module Rackstash @sink.flows end + # (see Sink#reopen) + def reopen + @sink.reopen + end + # (see Buffer#tags) def tags buffer.tags diff --git a/spec/rackstash/logger_spec.rb b/spec/rackstash/logger_spec.rb index 4a22e6a..31bce6b 100644 --- a/spec/rackstash/logger_spec.rb +++ b/spec/rackstash/logger_spec.rb @@ -38,6 +38,13 @@ describe Rackstash::Logger do 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 it 'forwards to the sink' do expect(logger.sink).to receive(:default_fields) @@ -73,7 +80,6 @@ describe Rackstash::Logger do end end - describe '#formatter' do it 'defaults to a Rackstash::Formatter' do expect(logger.formatter).to be_a Rackstash::Formatter @@ -160,6 +166,13 @@ describe Rackstash::Logger do end end + describe '#reopen' do + it 'forwards to the sink' do + expect(logger.sink).to receive(:reopen) + logger.reopen + end + end + describe '#sink' do it 'returns the created sink' do expect(logger.sink).to be_a Rackstash::Sink