log windows

vostok · Aug 10, 2022 · 5b2e286 · 5b2e286
1 parent 3554a72
commit 5b2e286
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 0 deletions.
diff --git a/Vostok.Hercules.Consumers/Helpers/Window.cs b/Vostok.Hercules.Consumers/Helpers/Window.cs
@@ -55,5 +55,8 @@ public bool ExistsForTooLong(bool restartPhase = false)
 
  public void Flush() =>
  implementation.Flush(End);
+
+ public override string ToString() =>
+ $"{nameof(FirstEventCoordinates)}: {FirstEventCoordinates}, {nameof(Start)}: {Start}, {nameof(End)}: {End}, {nameof(period)}: {period}, {nameof(lag)}: {lag}, {nameof(lastEventAdded)}: {lastEventAdded}, {nameof(EventsCount)}: {EventsCount}";
  }
 }
diff --git a/Vostok.Hercules.Consumers/Helpers/Windows.cs b/Vostok.Hercules.Consumers/Helpers/Windows.cs
@@ -1,5 +1,6 @@
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using Vostok.Commons.Time;
 using Vostok.Hercules.Client.Abstractions.Models;
 
@@ -84,5 +85,8 @@ private Window<T, TKey> CreateWindow(T @event, DateTimeOffset timestamp, StreamC
  var result = new Window<T, TKey>(settings.CreateWindow(key), coordinates, start, start + period, period, lag);
  return result;
  }
+
+ public override string ToString() =>
+ $"{nameof(LastEventAdded)}: {LastEventAdded}, {nameof(key)}: {key}, {nameof(minimumAllowedTimestamp)}: {minimumAllowedTimestamp}, {nameof(maximumObservedTimestamp)}: {maximumObservedTimestamp} {nameof(windows)}:\n{string.Join("\n", windows.Select(w => w.ToString()))}";
  }
 }
diff --git a/Vostok.Hercules.Consumers/WindowedStreamConsumer.cs b/Vostok.Hercules.Consumers/WindowedStreamConsumer.cs
@@ -79,6 +79,7 @@ private async Task Stop(StreamCoordinates rightCoordinates)
  {
  await settings.LeftCoordinatesStorage.AdvanceAsync(leftCoordinates).ConfigureAwait(false);
  LogCoordinates("Stop", leftCoordinates, rightCoordinates);
+ LogWindows();
  }
 
  private async Task Restart(StreamCoordinates rightCoordinates)
@@ -135,6 +136,7 @@ private async Task RestartWindows(StreamCoordinates rightCoordinates)
  FlushWindows();
 
  LogCoordinates("Restarted", leftCoordinates, rightCoordinates);
+ LogWindows();
  }
 
  private async Task<long> RestartPartition(int partition, int partitionsCount, long start, long end)
@@ -228,5 +230,8 @@ private void LogCoordinates(string message, StreamCoordinates left, StreamCoordi
  LogCoordinates(message + " left", left);
  LogCoordinates(message + " right", right);
  }
+
+ private void LogWindows() =>
+ log.Info("Windows: {{Windows}}.", windows.ToString());
  }
 }