ingestpdf

Documentation

Index

• func NewWorkerPool(num int, ingestTimeout time.Duration, doIt func(job *JobStruct) error, ...) (chan *JobStruct, io.Closer)
• type IngesterPdf
  • func NewIngester(dbClient mediaserverproto.DatabaseClient, vfs fs.FS, concurrentWorkers int, ...) (*IngesterPdf, error)
  • func (i *IngesterPdf) Close() error
  • func (i *IngesterPdf) Start() error
• type JobStruct
• type WriterNopcloser
  • func (WriterNopcloser) Close() error

Functions

func NewWorkerPool

func NewWorkerPool(num int, ingestTimeout time.Duration, doIt func(job *JobStruct) error, logger zLogger.ZLogger) (chan *JobStruct, io.Closer)

Types

type IngesterPdf

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

func NewIngester

func NewIngester(dbClient mediaserverproto.DatabaseClient, vfs fs.FS, concurrentWorkers int, ingestTimeout, ingestWait time.Duration, gsPath string, gsParams []string, tempDir string, logger zLogger.ZLogger) (*IngesterPdf, error)

func (*IngesterPdf) Close

func (i *IngesterPdf) Close() error

func (*IngesterPdf) Start

func (i *IngesterPdf) Start() error

type JobStruct

type JobStruct struct {
	Width    int64
	Height   int64
	Duration int64
	Size     int64
	MimeType string
	Path     string
	Storage  *storageStruct
	Missing  []string
	// contains filtered or unexported fields
}

type WriterNopcloser

type WriterNopcloser struct {
	io.Writer
}

func (WriterNopcloser) Close

func (WriterNopcloser) Close() error