From fc4a917b71f4f1130dc4436bb7e11b8f86e9993b Mon Sep 17 00:00:00 2001 From: Holger Just Date: Fri, 21 Jul 2017 16:44:11 +0200 Subject: [PATCH] Forward Logger#close and Logger#reopen to the Sink --- lib/rackstash/logger.rb | 10 ++++++++++ spec/rackstash/logger_spec.rb | 15 ++++++++++++++- 2 files changed, 24 insertions(+), 1 deletion(-) 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