watch

type Changes struct {
	// Dirs are the directories whose entries changed, each with its
	// ancestors.
	Dirs map[string]int64 `json:"dirs,omitempty"`
	// Trees are the directories everything under which changed, as one
	// created or moved in.
	Trees map[string]int64 `json:"trees,omitempty"`
	// Unwatched are the subtrees the source can't follow, with why; they
	// count as changed until the source starts again.
	Unwatched map[string]string `json:"unwatched,omitempty"`
}

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

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

type Options struct {
	// MinGap is the least time from a run's start to a run on change.
	MinGap time.Duration
	// FullReadEvery is how often a run reads everything whatever the
	// tracker says; zero never.
	FullReadEvery time.Duration
	// Settings fingerprints what besides the tree decides what a run
	// reads, such as its filters; a run with other settings reads
	// everything.
	Settings string
}

type Position struct {
	Stream string `json:"stream"`
	Seq    int64  `json:"seq"`
}

type Record struct {
	Position Position  `json:"position"`
	Commit   []byte    `json:"commit"`
	Settings string    `json:"settings"`
	FullAt   time.Time `json:"full_at"`
}

type Run struct {
	Set string
	// At is the position to record once the run succeeds; zero when there
	// is none.
	At Position
	// Unchanged reports the directories the run takes from the set's
	// latest commit, for job.PathSettings.Unchanged; nil reads everything.
	Unchanged func(rel string) bool
	// Full is why the run reads everything, one of the Full reasons; empty
	// when Unchanged is set.
	Full string
	// Detail says more about Full, such as why the tracker isn't following.
	Detail string
	// contains filtered or unexported fields
}

type Schedule struct {
	Store   Store
	Trigger Trigger
	// Now is the clock; nil is time.Now.
	Now    func() time.Time
	Logger *slog.Logger
	// contains filtered or unexported fields
}

type Source interface {
	// Backend names how the source follows the root, as inotify.
	Backend() string
	// Now is the position of the present: a change after it has a Seq at or
	// past its Seq.
	Now() (Position, error)
	// Read is what changed from from on, or ErrInDoubt, and the position it
	// read to, which the next Read starts from.
	Read(from Position) (*Changes, Position, error)
	Close() error
}

type State struct {
	TrackerState
	Watched bool `json:"watched"`
}

type Store interface {
	Load(set string) (Record, bool, error)
	Save(set string, r Record) error
}

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

type TrackerState struct {
	// Backend names the source's backend; empty before one opened.
	Backend   string `json:"backend,omitempty"`
	Following bool   `json:"following"`
	// Reason is why the tracker isn't following, or last lost track.
	Reason string `json:"reason,omitempty"`
	// Unwatched are the subtrees it can't follow, with why.
	Unwatched map[string]string `json:"unwatched,omitempty"`
}

type Trigger interface {
	RunNow(set string)
}