diff --git a/lib/rackstash/logger.rb b/lib/rackstash/logger.rb index 73bdb1c..c2c94b2 100644 --- a/lib/rackstash/logger.rb +++ b/lib/rackstash/logger.rb @@ -102,11 +102,37 @@ module Rackstash end end + # (see Sink#default_fields) + def default_fields + @sink.default_fields + end + + # (see Sink#default_fields=) + def default_fields=(fields) + @sink.default_fields = fields + end + + # (see Sink#default_tags) + def default_tags + @sink.default_tags + end + + # (see Sink#default_tags=) + def default_tags=(tags) + @sink.default_tags = tags + end + # (see Buffer#fields) def fields buffer.fields end + # (see Sink#flows) + # @!attribute [r] flows + def flows + @sink.flows + end + # (see Buffer#tags) def tags buffer.tags diff --git a/spec/rackstash/logger_spec.rb b/spec/rackstash/logger_spec.rb index 927ff18..4a22e6a 100644 --- a/spec/rackstash/logger_spec.rb +++ b/spec/rackstash/logger_spec.rb @@ -38,6 +38,42 @@ describe Rackstash::Logger do end end + describe '#default_fields' do + it 'forwards to the sink' do + expect(logger.sink).to receive(:default_fields) + logger.default_fields + end + end + + describe '#default_fields=' do + it 'forwards to the sink' do + expect(logger.sink).to receive(:default_fields=).with({ 'key' => 'value' }) + logger.default_fields = { 'key' => 'value' } + end + end + + describe '#default_tags' do + it 'forwards to the sink' do + expect(logger.sink).to receive(:default_tags) + logger.default_tags + end + end + + describe '#default_tags=' do + it 'forwards to the sink' do + expect(logger.sink).to receive(:default_tags=).with(['tag']) + logger.default_tags = ['tag'] + end + end + + describe '#flows' do + it 'forwards to the sink' do + expect(logger.sink).to receive(:flows) + logger.flows + end + end + + describe '#formatter' do it 'defaults to a Rackstash::Formatter' do expect(logger.formatter).to be_a Rackstash::Formatter