Forward config methods for the Sink on the Logger

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

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