checkpoint

type AggregatorSpillEntry struct {
	// Dir is the directory containing gob-encoded spill files.
	Dir string `json:"dir,omitempty"`

	// Count is the number of spill files in Dir.
	Count int `json:"count,omitempty"`
}

type Checkpointable interface {
	// SaveCheckpoint writes analyzer state to the given directory.
	SaveCheckpoint(dir string) error

	// LoadCheckpoint restores analyzer state from the given directory.
	LoadCheckpoint(dir string) error

	// CheckpointSize returns the estimated size of the checkpoint in bytes.
	CheckpointSize() int64
}

type Codec = persist.Codec

type GobCodec = persist.GobCodec

type JSONCodec = persist.JSONCodec

type Manager struct {
	BaseDir  string
	RepoHash string
	MaxAge   time.Duration
	MaxSize  int64
}

type Metadata struct {
	Version        int               `json:"version"`
	RepoPath       string            `json:"repo_path"`
	RepoHash       string            `json:"repo_hash"`
	CreatedAt      string            `json:"created_at"`
	Analyzers      []string          `json:"analyzers"`
	StreamingState StreamingState    `json:"streaming_state"`
	Checksums      map[string]string `json:"checksums"`
}

type Persister[T any] = persist.Persister[T]

type StreamingState struct {
	TotalCommits     int    `json:"total_commits"`
	ProcessedCommits int    `json:"processed_commits"`
	CurrentChunk     int    `json:"current_chunk"`
	TotalChunks      int    `json:"total_chunks"`
	LastCommitHash   string `json:"last_commit_hash"`
	LastTick         int    `json:"last_tick"`

	// AggregatorSpills records the spill state of each aggregator at checkpoint time.
	// Indexed by analyzer position in the Runner.Analyzers slice.
	// Nil entries mean the analyzer has no aggregator (plumbing, file_history).
	AggregatorSpills []AggregatorSpillEntry `json:"aggregator_spills,omitempty"`
}