state

type FileRangeManager Manager[Range, RangeList]

type FileRangeQueue Queue[Range]

type Manager[I, O any] interface {
	Queue[I]
	// Restore loads the previous state.
	Restore() (O, error)
	// Run starts the update/save loop.
	Run(ch Notification)
}

type ManagerConfig struct {
	// Name is the metadata that will be persisted in the last line of the state file.
	Name string
	// StateFileDir is the directory where the state file will be written to.
	StateFileDir string
	// StateFilePrefix is an optional prefix added to the filename. Can be used to group state files.
	StateFilePrefix string
	// QueueSize determines the size of the internal buffer for pending state changes.
	QueueSize int
	// SaveInterval determines how often the state is persisted.
	SaveInterval time.Duration
	// MaxPersistedItems is the maximum number of items to persist in the saved state. If zero or negative, the
	// persistence is unbounded.
	MaxPersistedItems int
}

type Notification struct {
	Delete chan struct{}
	Done   chan struct{}
}

type Queue[T any] interface {
	ID() string
	// Enqueue the current state in memory.
	Enqueue(state T)
}

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

type RangeList []Range

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

type RangeTracker interface {
	encoding.TextMarshaler
	encoding.TextUnmarshaler
	// Insert a Range into the store. Returns false if the Range is already contained by another Range in the store or is
	// invalid.
	Insert(Range) bool
	// Ranges returns all ranges in sorted order.
	Ranges() RangeList
	// Len returns the number of ranges in the store.
	Len() int
	// Clear all stored ranges.
	Clear()
}