walutil

Documentation

Index

• func FlushInterval(logger *wal.Logger, d time.Duration, onError func(error))

Functions

func FlushInterval

func FlushInterval(logger *wal.Logger, d time.Duration, onError func(error))

FlushInterval creates a time.Timer to fire after the given time.Duration d, to call logger.Flush(). If logger.Flush() returns a non-nil error, the onError function is called, with the non-nil error as an argument.

If the non-nil error returned from logger.Flush() is wal.ErrLoggerClosed, this function will exit. It is recommended to call this function in its own goroutine.

logger, err := wal.NewLogger(NewDirectorySink("/tmp/wal.d"))
if err != nil {
	...
}

go FlushInterval(logger, 10*time.Second, func(err error) {
	log.Println("error flushing wal:", err)
})