watcher

package

v0.0.14 Latest Latest Go to latest Published: Aug 1, 2025 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ProcessorInterface interface {
	IsPathBeingProcessed(path string) bool
}

ProcessorInterface defines the interface for checking running jobs

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

func New(
	cfg config.WatcherConfig,
	q queue.QueueInterface,
	processor ProcessorInterface,
	watchFolder string,
) *Watcher

func (w *Watcher) ClearQueue() error

ClearQueue removes all completed and failed items from the queue via queue

func (w *Watcher) Close() error

Close does nothing for the simple watcher (queue is managed separately)

func (w *Watcher) GetQueueItems() ([]queue.QueueItem, error)

GetQueueItems returns queue items via the queue

func (w *Watcher) GetQueueStats() (map[string]interface{}, error)

GetQueueStats returns statistics about the queue via queue

func (w *Watcher) RemoveFromQueue(id string) error

RemoveFromQueue removes an item from the queue via queue

func (w *Watcher) Start(ctx context.Context) error

func (w *Watcher) TriggerScan(ctx context.Context)

TriggerScan triggers an immediate directory scan