file_state_handler

type FileFilter func(string, FileState) bool

type FileState struct {
	Size         int64        `json:"size"`
	StartTime    int64        `json:"start_time,omitempty"`
	EndTime      int64        `json:"end_time,omitempty"`
	Unsupported  bool         `json:"unsupported,omitempty"`
	IsDir        bool         `json:"is_dir,omitempty"`
	IsListening  bool         `json:"is_listening,omitempty"`
	IsCollecting bool         `json:"is_collecting,omitempty"`
	ProcessState processState `json:"process_state,omitempty"`
	TooOld       bool         `json:"too_old,omitempty"`
	Pathname     string       `json:"-"` // Pathname is output only for the Files method
}

type FileStateHandler interface {
	// UpdateDirs updates the directories being monitored.
	UpdateDirs(conf config.DefaultModConfConfig) error

	// Files returns filename and filestate pairs that match the given filters.
	Files(filters ...FileFilter) []FileState

	// UpdateFilesProcessState updates the state of files that are ready to process.
	// This should be called before processing files
	UpdateFilesProcessState() error

	// MarkProcessedFile updates the state of files that were ready to process
	// to mark them as processed.
	MarkProcessedFile(filename string) error

	// GetFileHandler returns the handler for a given file path.
	GetFileHandler(filePath string) file_handlers.Interface
}

type SavedState struct {
	State      map[string]FileState `json:"state"`
	SrcDirs    []string             `json:"src_dirs"`
	ListenDirs []string             `json:"listen_dirs"`
}