💄

Author: lazandrei19

fluent-plugin-logtail.gemspec

@@ -3,7 +3,7 @@ require 'date'
 
 Gem::Specification.new do |s|
   s.name        = 'fluent-plugin-logtail'
-  s.version     = '0.1.2'
+  s.version     = '0.2.1'
   s.date        = Date.today.to_s
   s.summary     = 'Logtail.com plugin for Fluentd'
   s.description = 'Streams Fluentd logs to the Logtail.com logging service.'

spec/fluent/plugin/out_logtail_spec.rb

@@ -11,7 +11,7 @@
   let(:cloud_config) do
     %{
       source_token  abcd1234
-      ingesting_host s1234.g1.betterstackdata.com
+      ingesting_host s1234.eu-nbg-2.betterstackdata.com
     }
   end
 
@@ -48,16 +48,16 @@ def format(tag, time, record)
   end
 
   describe "#write" do
-    it "should send a chunked request to the Logtail API" do
-      stub = stub_request(:post, "https://s1234.g1.betterstackdata.com/").
+    it "should send a chunked request to the Logtail API using default host" do
+      stub = stub_request(:post, "https://in.logs.betterstack.com/").
         with(
           :body => start_with("\xDD\x00\x00\x00\x01\x85\xA3age\x1A\xAArequest_id\xA242\xA9parent_id\xA6parent\xAArouting_id\xA7routing\xA2dt\xB4".force_encoding("ASCII-8BIT")),
           :headers => {'Accept'=>'*/*', 'Accept-Encoding'=>'gzip;q=1.0,deflate;q=0.6,identity;q=0.3', 'Authorization'=>'Bearer abcd1234', 'Content-Type'=>'application/msgpack', 'User-Agent'=>'Logtail Fluentd/0.1.1'}
         ).
         to_return(:status => 202, :body => "", :headers => {})
 
-      cloud_driver.emit(record)
-      cloud_driver.run
+      driver.emit(record)
+      driver.run
 
       expect(stub).to have_been_requested.times(1)
     end
@@ -83,15 +83,15 @@ def format(tag, time, record)
 
   describe "#write to cloud" do
     it "should send a chunked request to the Logtail API" do
-      stub = stub_request(:post, "https://in.logs.betterstack.com/").
+      stub = stub_request(:post, "https://s1234.eu-nbg-2.betterstackdata.com/").
         with(
           :body => start_with("\xDD\x00\x00\x00\x01\x85\xA3age\x1A\xAArequest_id\xA242\xA9parent_id\xA6parent\xAArouting_id\xA7routing\xA2dt\xB4".force_encoding("ASCII-8BIT")),
           :headers => {'Accept'=>'*/*', 'Accept-Encoding'=>'gzip;q=1.0,deflate;q=0.6,identity;q=0.3', 'Authorization'=>'Bearer abcd1234', 'Content-Type'=>'application/msgpack', 'User-Agent'=>'Logtail Fluentd/0.1.1'}
         ).
         to_return(:status => 202, :body => "", :headers => {})
 
-      driver.emit(record)
-      driver.run
+      cloud_driver.emit(record)
+      cloud_driver.run
 
       expect(stub).to have_been_requested.times(1)
     end