eosswedenorg/thalos
1
0
Fork 0
mirror of https://github.com/eosswedenorg/thalos synced 2026-06-16 04:24:56 +02:00
Code Releases Activity

app/ship_processor.go: Add Close() method that closes the writer.

Browse source
This commit is contained in:
Henrik Hautakoski 2023-03-29 11:53:11 +02:00
parent c225505143
commit 1f09993925
1 changed files with 4 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

4
app/ship_processor.go
View file

@ -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()
}