processor

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

type ProcessorOptions struct {
	Queue                     *queue.Queue
	Postie                    *postie.Postie
	Config                    config.QueueConfig
	OutputFolder              string
	EventEmitter              func(eventName string, optionalData ...interface{})
	DeleteOriginalFile        bool
	MaintainOriginalExtension bool
	WatchFolder               string // Path to the watch folder for maintaining folder structure
}

type RunningJobDetails struct {
	ID       string  `json:"id"`
	Path     string  `json:"path"`
	FileName string  `json:"fileName"`
	Size     int64   `json:"size"`
	Status   string  `json:"status"`
	Stage    string  `json:"stage"`
	Progress float64 `json:"progress"`
}

type RunningJobItem struct {
	ID     string `json:"id"`
	Status string `json:"status"`
}