log exit messages

vinceanalytics · Feb 8, 2024 · f262706 · f262706
1 parent d05e666
commit f262706
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 2 deletions.
diff --git a/lsm/lsm.go b/lsm/lsm.go
@@ -228,7 +228,11 @@ func (lsm *Tree[T]) Start(ctx context.Context) {
 	lsm.log.Info("Start compaction loop", "interval", interval.String(),
 		"compactSize", units.BytesSize(float64(lsm.opts.compactSize)))
 	tick := time.NewTicker(interval)
-	defer tick.Stop()
+	defer func() {
+		tick.Stop()
+		lsm.log.Info("exiting compaction loop")
+	}()
+
 	for {
 		select {
 		case <-ctx.Done():

diff --git a/session/session.go b/session/session.go
@@ -69,6 +69,9 @@ func (s *Session) Queue(ctx context.Context, req *v1.Event) {
 
 func (s *Session) doProcess(ctx context.Context) {
 	s.log.Info("Starting events processing loop")
+	defer func() {
+		s.log.Info("Exiting events processing loop")
+	}()
 	for {
 		select {
 		case <-ctx.Done():
@@ -128,8 +131,12 @@ func (s *Session) Start(ctx context.Context) {
 
 func (s *Session) doFlush(ctx context.Context) {
 	s.log.Info("Starting session flushing loop", "interval", DefaultFlushInterval.String())
+
 	tk := time.NewTicker(DefaultFlushInterval)
-	defer tk.Stop()
+	defer func() {
+		tk.Stop()
+		s.log.Info("Exiting flushing loop")
+	}()
 
 	for {
 		select {