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"`
	ModifyTime  int64 `json:"modify_time,omitempty"`
	Unsupported bool  `json:"unsupported,omitempty"`

	TooOld       bool         `json:"too_old,omitempty"`
	IsCollecting bool         `json:"is_collecting,omitempty"`
	IsDir        bool         `json:"is_dir,omitempty"`
	IsListening  bool         `json:"is_listening,omitempty"`
	ProcessState processState `json:"process_state,omitempty"`
	Pathname     string       `json:"-"` // Pathname is output only for the Files method
}

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

	// UpdateCollectDirs updates the directories being collected.
	UpdateCollectDirs(conf config.DefaultModConfConfig) error

	// Files returns filename and file state 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"`
	ListenDirs  []string             `json:"listen_dirs"`
	CollectDirs []string             `json:"collect_dirs,omitempty"`
}