processor

package
v0.0.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 12, 2025 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Processor

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

func New

func New(opts ProcessorOptions) *Processor

func (*Processor) CancelJob

func (p *Processor) CancelJob(jobID string) error

CancelJob cancels a running job by its ID

func (*Processor) GetRunningJobDetails

func (p *Processor) GetRunningJobDetails() []*RunningJobDetails

GetRunningJobDetails returns detailed information about currently running jobs

func (*Processor) GetRunningJobItems

func (p *Processor) GetRunningJobItems() []RunningJobItem

GetRunningJobItems returns detailed information about currently running jobs

func (*Processor) GetRunningJobs

func (p *Processor) GetRunningJobs() map[string]bool

GetRunningJobs returns a map of currently running job IDs

func (*Processor) IsPathBeingProcessed

func (p *Processor) IsPathBeingProcessed(path string) bool

IsPathBeingProcessed checks if a file path is currently being processed

func (*Processor) Start

func (p *Processor) Start(ctx context.Context) error

Start begins processing files from the queue

type ProcessorOptions

type ProcessorOptions struct {
	Queue                     *queue.Queue
	Postie                    *postie.Postie
	Config                    config.QueueConfig
	OutputFolder              string
	EventEmitter              func(eventName string, optionalData ...interface{})
	DeleteOriginalFile        bool
	MaintainOriginalExtension bool
}

type RunningJobDetails

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"`
}

RunningJobDetails stores detailed information about a running job

type RunningJobItem

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

RunningJobItem represents a running job for the frontend (kept for backward compatibility)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL