Implemented dropping events, rejected by Loki (#53)

serilog-contrib · Aug 30, 2021 · 30aa016 · 30aa016
1 parent 7f00aff
commit 30aa016
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/src/Serilog.Sinks.Grafana.Loki/LokiSink.cs b/src/Serilog.Sinks.Grafana.Loki/LokiSink.cs
@@ -134,12 +134,14 @@ private async Task OnTick()
                         }
                         else
                         {
-                            _connectionSchedule.MarkFailure();
-
                             SelfLog.WriteLine(
-                                "Received failure on HTTP shipping {0}: {1}",
-                                response.StatusCode,
-                                await response.Content.ReadAsStringAsync().ConfigureAwait(false));
+                                "Received failure on HTTP shipping ({0}): {1}. {2} log events will be dropped",
+                                (int)response.StatusCode,
+                                await response.Content.ReadAsStringAsync().ConfigureAwait(false),
+                                _waitingBatch.Count);
+
+                            _connectionSchedule.MarkFailure();
+                            _waitingBatch.Clear();
 
                             break;
                         }