flusher

package

v1.9.13-beta3 Latest Latest Go to latest Published: Mar 10, 2026 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Flushable interface {
	FlushDirty() error
}

Flushable is implemented by any store that can flush dirty records to disk.

type Flusher struct {
	// contains filtered or unexported fields
}

Flusher periodically flushes dirty records from all registered stores to disk.

func NewFlusher(interval time.Duration) *Flusher

NewFlusher creates a new Flusher that flushes at the given interval.

func (f *Flusher) AddStore(s Flushable)

AddStore registers a store to be flushed periodically.

func (f *Flusher) Start()

Start begins the background flush loop.

func (f *Flusher) Stop()

Stop signals the flusher to perform a final flush and stop. Blocks until the flush loop has exited.