unaligned

Documentation

Index

• type Compactor
• type GCEventsWAL

Types

type Compactor

type Compactor interface {
	// Start starts the compactor
	Start(ctx context.Context) error
	// Stop stops the compactor
	Stop() error
}

Compactor compacts the unalignedWAL by deleting the persisted messages which belongs to the materialized window.

type GCEventsWAL

type GCEventsWAL interface {
	// PersistGCEvent persists the GC event of the window
	PersistGCEvent(window window.TimedWindow) error
	// Close closes the GCEventsWAL
	Close() error
}

GCEventsWAL persists the GC events from PnF of unaligned windows.