Add Flush method

This commit is contained in:
Thomas Roehl 2021-11-26 19:13:48 +01:00
parent 06ab58dc92
commit aa842a8a9c

View File

@ -127,6 +127,10 @@ func (s *SqliteSink) Write(measurement string, tags map[string]string, fields ma
return nil
}
func (s *SqliteSink) Flush() error {
return nil
}
func (s *SqliteSink) Close() {
log.Print("Closing Sqlite3 database ", s.database)
if s.db != nil {