engine

package

v0.4.0 Latest Latest Go to latest Published: Jan 19, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type DownloadJob struct {
	Segment    nzb.Segment
	File       *nzb.DownloadFile
	Groups     []string
	Offset     int64
	RetryCount int
}

type DownloadResult struct {
	Job   DownloadJob
	Error error
}

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

func NewFileWriter() *FileWriter

func (fw *FileWriter) CloseAll()

func (fw *FileWriter) CloseFile(path string, finalSize int64) error

func (fw *FileWriter) PreAllocate(path string, size int64) error

func (fw *FileWriter) WriteAt(path string, data []byte, offset int64) error

WriteAt finds the handle and performs a thread-safe write

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

func NewService(ctx *app.Context, writer *FileWriter) *Service

func (s *Service) Download(ctx context.Context, nzb *nzb.Model) error

type WriteRequest struct {
	FilePath string
	Offset   int64
	Data     []byte
	Done     chan error // Feedback loop for the worker
}