From 1f09993925ecd3b4b2f594aa99d643843ef42c09 Mon Sep 17 00:00:00 2001 From: Henrik Hautakoski Date: Wed, 29 Mar 2023 11:53:11 +0200 Subject: [PATCH] app/ship_processor.go: Add Close() method that closes the writer. --- app/ship_processor.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/app/ship_processor.go b/app/ship_processor.go index f6746a4..8be8926 100644 --- a/app/ship_processor.go +++ b/app/ship_processor.go @@ -156,3 +156,7 @@ func (processor *ShipProcessor) processTraces(traces []*ship.TransactionTraceV0) log.WithError(err).Error("Failed to send messages") } } + +func (processor *ShipProcessor) Close() error { + return processor.writer.Close() +}